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>, ) -> Self

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

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

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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

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