Skip to main content

spawn_writer_task

karyon_p2p::peer::connection

Function spawn_writer_task 

Source 
fn spawn_writer_task(
    task_group: &TaskGroup,
    writer: FramedWriter<PeerNetMsgCodec>,
    queue: Arc<AsyncQueue<PeerNetMsg>>,
)
Expand description

Spawn a task that drains queue into writer. Exits when the writer fails (peer hung up).