Struct TeamRunner 

pub struct TeamRunner { /* private fields */ }

Sequential team execution engine.

Binds agent roles to async callables and runs them in sequence, passing each agent’s output as the next agent’s input.

Implementations

impl TeamRunner

pub fn new(max_iterations: usize) -> Self

Create a new TeamRunner with the given max iteration limit.

Panics

Panics if max_iterations == 0.

pub fn bind<F, Fut>(&mut self, role: impl Into<String>, agent: F)

where F: Fn(String) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<String>> + Send + 'static,

Bind an agent closure to a role name.

The closure receives the current input and returns the agent’s response.

pub fn set_sequence(&mut self, roles: &[&str])

Set the execution sequence of role names.

pub fn is_bound(&self, role: &str) -> bool

Check if a role has been bound.

pub async fn run(&self, input: &str) -> Result<String>

Execute the team pipeline sequentially.

Each agent in the sequence receives the previous agent’s output. Returns the last agent’s output as the final result.

Errors

Returns an error if:

• A bound agent returns an error
• The sequence is empty
• A role in the sequence is not bound
• max_iterations is exceeded