Struct DispatchTextAgent 

pub struct DispatchTextAgent { /* private fields */ }

Fire-and-forget background task launcher with global task budget.

Launches each child agent as a background tokio::spawn task, stores handles in a TaskRegistry, and returns immediately.

Implementations

impl DispatchTextAgent

pub fn new( name: impl Into<String>, children: Vec<(String, Arc<dyn TextAgent>)>, registry: TaskRegistry, budget: Arc<Semaphore>, ) -> DispatchTextAgent

Create a new dispatch agent with named children and a concurrency budget.

pub fn with_middleware_chain(self, chain: MiddlewareChain) -> DispatchTextAgent

Attach a middleware chain. AgentEvent::AgentStarted is emitted through it as each child task is launched, and AgentEvent::AgentCompleted from inside the detached task when the child finishes (the chain is cloned into the task, so this fires even after run has returned).

Trait Implementations

impl TextAgent for DispatchTextAgent

fn name(&self) -> &str

Human-readable name for logging and debugging.

fn run<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 State, ) -> Pin<Box<dyn Future<Output = Result<String, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DispatchTextAgent: 'async_trait,

Execute this agent. Reads/writes state. Returns the final text output.

fn run_with<'life0, 'life1, 'async_trait>( &'life0 self, request: RunRequest, state: &'life1 State, ) -> Pin<Box<dyn Future<Output = Result<RunResult, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Run one request and report everything it produced: the reply, the turns to append to a conversation, token usage and tool calls.

fn run_stream<'a>( &'a self, request: RunRequest, state: State, ) -> Pin<Box<dyn Stream<Item = Result<RunEvent, AgentError>> + Send + 'a>>

Run one request as a stream of RunEvents: text as the model writes it, each tool call and result, then RunEvent::Finished.

fn stream( &self, prompt: impl Into<String>, ) -> Pin<Box<dyn Stream<Item = Result<RunEvent, AgentError>> + Send + '_>>

where Self: Sized,

Stream the reply to one question, with no history and fresh state.

fn ask<'life0, 'async_trait>( &'life0 self, prompt: impl Into<String> + Send + 'async_trait, ) -> Pin<Box<dyn Future<Output = Result<String, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Sized + 'async_trait,

Ask one question, with no history and fresh state, and get the reply.

fn ask_as<'life0, 'async_trait, T>( &'life0 self, prompt: impl Into<String> + Send + 'async_trait, ) -> Pin<Box<dyn Future<Output = Result<T, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Sized + 'async_trait, T: DeserializeOwned + JsonSchema + Send + 'async_trait,

Ask one question and get the reply as a T.

fn chat(&self) -> Chat<&Self>

where Self: Sized,

Start a conversation that remembers its turns. See Chat.