pub async fn mesh(
members: &Members,
exchange: &TcpListener,
handle: Handle,
flows: usize,
window: usize,
) -> Result<WorkerExchange>Expand description
Open the exchange mesh from a settled membership: one Link per peer — connect to lower ids,
accept from higher ids on exchange — returning the WorkerExchange start_worker consumes.
Accept and connect run concurrently so no worker deadlocks waiting on a peer that is waiting on
it.