Struct AsyncTaskRunner 

pub struct AsyncTaskRunner { /* private fields */ }

Handle used by tools to submit background work.

Cheap to clone (just an mpsc::Sender); one is placed in every ToolContext. The matching Receiver lives on the Agent, which select!s on it alongside user input.

Implementations

impl AsyncTaskRunner

pub fn new(done_tx: Sender<AsyncTaskDone>) -> Self

Create a runner wired to the Agent’s done channel.

pub fn submit( &self, tool_call_id: String, session_id: SessionId, tool_name: String, work: AsyncTaskWork, cancel: CancellationToken, ) -> String

Spawn work as a background task and return its task_id immediately.

The caller (the tool’s execute) should return a ToolResult::pending placeholder using this task_id. When work resolves - or cancel is triggered - the result is sent to the Agent for reinjection.

If the Agent has exited, done_tx.send fails silently and the result is dropped (side effects like saved files already happened).

Trait Implementations

impl Clone for AsyncTaskRunner

fn clone(&self) -> AsyncTaskRunner

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.