async fn broadcast_shutdown(
queues: &HashMap<ProtocolID, Arc<AsyncQueue<ProtocolEvent>>>,
)Expand description
Push ProtocolEvent::Shutdown into every recv queue, waking
blocked recv callers.
async fn broadcast_shutdown(
queues: &HashMap<ProtocolID, Arc<AsyncQueue<ProtocolEvent>>>,
)Push ProtocolEvent::Shutdown into every recv queue, waking
blocked recv callers.