Skip to main content

broadcast_shutdown

Function broadcast_shutdown 

Source
async fn broadcast_shutdown(
    queues: &HashMap<ProtocolID, Arc<AsyncQueue<ProtocolEvent>>>,
)
Expand description

Push ProtocolEvent::Shutdown into every recv queue, waking blocked recv callers.