Skip to main content

spawn_quic_reader

Function spawn_quic_reader 

Source
fn spawn_quic_reader(
    task_group: &TaskGroup,
    proto_id: ProtocolID,
    reader: FramedReader<PeerNetMsgCodec>,
    recv_queue: Arc<AsyncQueue<ProtocolEvent>>,
)
Expand description

Spawn a per-stream QUIC reader task. The stream is already keyed by protocol id, so messages go straight into recv_queue.