Skip to main content

spawn_writer_task

ferrous_browser::cdp

Function spawn_writer_task 

Source 
pub fn spawn_writer_task(
    sink: WebSocketSink,
    rx: UnboundedReceiver<Message>,
    cdp: Arc<CDPClient>,
) -> JoinHandle<()>
Expand description

Spawn the dedicated writer task that drains the mpsc and writes to the WebSocket sink. The task ends when the channel closes (all senders dropped) or when a write fails. On a write failure it also fails every in-flight CDP request via fail_all_pending so callers see an immediate error instead of the 30 s timeout.