establish_connection

finmqtt_tokio::connection::event_loop::connect

Function establish_connection 

pub(super) async fn establish_connection<T: Transport + Send + Sync + 'static>(
    transport: &T,
    options: &ClientOptions,
    clean_start: bool,
    client: &mut Client<JournaledSession>,
) -> Result<EstablishedConnection<ReadHalf<T::Io>, WriteHalf<T::Io>>, DisconnectReason>
Expand description

Performs TCP connect, send CONNECT, wait for CONNACK.