pub async fn run<'a, F, C>( conn: &Connection, client: &C, f: F, ) -> DisconnectedErrorwhere F: FnMut(C::Event), C: Client,