run

finmqtt_tokio::connection::event_loop

Function run 

pub async fn run<T: Transport + Send + Sync + 'static>(
    transport: T,
    options: ClientOptions,
    cmd_rx: Receiver<Command>,
    msg_tx: Sender<Message>,
    session: JournaledSession,
    journal_writer: Option<Writer>,
)