Skip to main content

spawn_drain

Function spawn_drain 

Source
pub fn spawn_drain(
    registry: Arc<ToolHandleRegistry>,
    handle_id: String,
    rx: Receiver<ToolStreamChunk>,
    cancel: CancellationToken,
)
Expand description

Spawn the drain task tying an executor’s chunk stream to the registry: forwards chunks until a terminal chunk, stream close, or cancellation. Returns immediately; the task owns the receiver.