Function timely::communication::allocator::zero_copy::tcp::send_loop

pub fn send_loop(
    writer: TcpStream, 
    sources: Vec<Sender<MergeQueue>, Global>, 
    process: usize, 
    remote: usize, 
    logger: Option<Logger<CommunicationEvent, CommunicationSetup>>
)

Repeatedly sends messages into a TcpStream.

The intended communication pattern is a sequence of (header, message)^* for valid messages, followed by a header for a zero length message indicating the end of stream.