Skip to main content

writer_loop

Function writer_loop 

Source
pub(crate) async fn writer_loop(
    writer: Box<dyn FrameSink>,
    out_rx: Receiver<Vec<u8>>,
)
Expand description

Drain the outbound frame queue into the connection’s write half. Runs as a dedicated task so background work can emit unsolicited frames (async STATUS_PENDING completions, oplock/lease breaks, CHANGE_NOTIFY) while the reader blocks on recv. Ends when every [mpsc::Sender] clone is dropped.