Struct JoinTextAgent 

pub struct JoinTextAgent { /* private fields */ }

Waits for dispatched background tasks and collects their results.

Implementations

impl JoinTextAgent

pub fn new(name: impl Into<String>, registry: TaskRegistry) -> JoinTextAgent

Create a new join agent that waits for dispatched tasks.

pub fn targets(self, names: Vec<String>) -> JoinTextAgent

Only wait for specific named tasks.

pub fn timeout(self, timeout: Duration) -> JoinTextAgent

Set a timeout for waiting.

Trait Implementations

impl TextAgent for JoinTextAgent

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, JoinTextAgent: 'async_trait,

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