Function mz_cluster::communication::await_connection

source ยท 
async fn await_connection(
    listener: &Listener,
    my_index: u64,
    my_epoch: ClusterStartupEpoch,
) -> Result<(Stream, u64), Error>