Function tcb::vv::communication::reader::start

pub fn start(
    stream: TcpStream, 
    middleware_channel: Sender<ClientPeerMiddleware>, 
    local_id: usize, 
    peer_id: usize, 
    setup_end_barrier: Arc<Barrier>
)

Starts a Reader thread that receives messages from a stream and sends them to the middleware.

Arguments

stream - TCP stream between the peers.

middleware_channel - Channel from the the Reader to the Middleware.

local_id - Local peer's globally unique id.

peer_id - Other peer's globally unique id.

setup_end_barrier - Barrier signalling the middleware connected to every peer.