Skip to main content

build_recv_queues

karyon_p2p::peer::connection

Function build_recv_queues 

Source 
fn build_recv_queues(
    proto_ids: impl IntoIterator<Item = ProtocolID>,
) -> HashMap<ProtocolID, Arc<AsyncQueue<ProtocolEvent>>>
Expand description

One bounded recv queue per protocol id.