pub(crate) async fn run_connect_with<I: ConnectIo>( client: &Client, provider_id: Option<String>, io: &mut I, ) -> Result<()>