pub type HandshakeStream<S = TcpStream> = ObservedStream<S, HandshakeClock>;Expand description
An accepted controller-listener connection, handed to
RaftListenerHandshake::upgrade.
Every read or write that moves bytes restarts the listener’s idle window,
as Kafka’s Selector refreshes a channel’s idle clock on every ready key.
The window closes a handshake that goes silent, not one that is slow. Once
the listener takes the upgraded stream for its request loop, the clock is
disarmed and the stream only passes bytes through.
Aliased Type§
pub struct HandshakeStream<S = TcpStream> { /* private fields */ }