[−][src]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.