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.