Function run_connection 

async fn run_connection<T: Transport + Send + Sync + 'static>(
    transport: &T,
    options: &ClientOptions,
    clean_start: bool,
    state: &mut LoopState<'_>,
) -> DisconnectReason