async fn await_connection( listener: &Listener, my_index: u64, my_epoch: ComputeStartupEpoch) -> Result<(Stream, u64), Error>