pub async fn run<'m, F, S>( conn: &Connection, server: &S, f: F, ) -> DisconnectedErrorwhere F: FnMut(S::Event), S: Server,