[][src]Function erdos::communication::create_tcp_streams

pub async fn create_tcp_streams<'_>(
    node_addrs: Vec<SocketAddr>,
    node_id: NodeId,
    logger: &'_ Logger
) -> Vec<(NodeId, TcpStream)>

Returns a vec of TCPStreams; one for each node pair.

The function creates a TCPStream to each node address. The node address vector stores the network address of each node, and is indexed by node id.