async fn start_connection( address: String, my_index: u64, my_epoch: ComputeStartupEpoch) -> Result<Stream, Error>