Skip to main content

ReadPump

Function ReadPump 

Source
async fn ReadPump(Stream: Streaming<Envelope>, State: Arc<Multiplexer>)
Expand description

Drain the inbound side of the bidirectional stream. Notifications fan out to the process-wide broadcast; responses wake the parked Request future. Reverse-RPC requests and cancellations are recorded for a follow-up phase.