Struct ParallelAgent 

pub struct ParallelAgent { /* private fields */ }

Runs sub-agents concurrently.

All sub-agents run in parallel via tokio::spawn. Each gets a fresh InvocationContext wrapping the same underlying AgentSession (shared state and session). All must complete before ParallelAgent returns.

If any sub-agent fails, its error is returned (first error wins when iterating over join handles in order).

Implementations

impl ParallelAgent

pub fn new(name: impl Into<String>, sub_agents: Vec<Arc<dyn Agent>>) -> Self

Create a new parallel agent with the given name and sub-agents.

Trait Implementations

impl Agent for ParallelAgent

fn name(&self) -> &str

Human-readable name for routing, logging, and debugging.

fn run_live<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut InvocationContext, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

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

Run this agent on a live session. Returns when the agent is done (turn complete, transfer, or disconnect).

fn sub_agents(&self) -> Vec<Arc<dyn Agent>>

Sub-agents this agent can transfer control to.

fn tools(&self) -> Vec<Tool>

Declare tools this agent provides (sent in the setup message).