Struct FanOutFanIn 

pub struct FanOutFanIn { /* private fields */ }

Fan-out/fan-in orchestrator (a form of Supervisor, P2-3).

Broadcasts the same task to N child orchestrators running in parallel (rate-limited by max_concurrency), then merges their outputs with an aggregator once all complete. Suited to “multi-role review / committee” scenarios: independent perspectives each compute their own, and a unified verdict is reached at the end.

The default aggregator joins with newlines; swap it via FanOutFanIn::with_aggregator for voting / best-of custom strategies. Any worker failure fails the whole run (errors are not swallowed).

Implementations

impl FanOutFanIn

pub fn new( workers: Vec<Arc<dyn Orchestrator<Input = AgentTask, Output = String>>>, ) -> Self

Construct from a set of homogeneous AgentTask -> String child orchestrators; aggregation defaults to newline-joining.

Real agents (Input=String) should be wrapped with crate::orchestration::task_adapter before being put into the worker list.

pub fn with_aggregator( self, aggregator: impl Fn(Vec<String>) -> String + Send + Sync + 'static, ) -> Self

Custom aggregator function (e.g. best-of, voting, join templates).

pub fn with_max_concurrency(self, n: usize) -> Self

Cap the number of parallel workers (at least 1).

Trait Implementations

impl Orchestrator for FanOutFanIn

type Input = AgentTask

Input type (usually a String objective/question).

type Output = String

Output type.

fn run_with_context<'life0, 'life1, 'async_trait>( &'life0 self, input: Self::Input, ctx: &'life1 RunContext, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, AgentError>> + Send + 'async_trait>>

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

Execution entry point carrying the run context.