Struct ParallelFlow 

pub struct ParallelFlow { /* private fields */ }

Fan-out the input to N branches, run them concurrently, return a JSON object keyed by branch name. First error fails the whole flow (other branches are dropped).

Implementations

impl ParallelFlow

pub fn new(name: impl Into<String>) -> Self

New empty parallel flow.

pub fn branch(self, key: impl Into<String>, flow: Arc<dyn Flow>) -> Self

Append a branch. The key becomes the JSON key in the output object. Duplicate keys overwrite — caller must ensure uniqueness.

pub fn branch_agent<A>(self, key: impl Into<String>, agent: A) -> Self

where A: Agent + 'static,

Convenience builder that wraps a concrete klieo_core::agent::Agent in crate::flow::AgentFlow + upcasts to Arc<dyn Flow> in one call. The key becomes the JSON key in the output object.

Trait Implementations

impl Flow for ParallelFlow

fn name(&self) -> &str

Stable flow name. Used in tracing spans.

fn run<'life0, 'async_trait>( &'life0 self, ctx: AgentContext, input: Value, ) -> Pin<Box<dyn Future<Output = Result<Value, FlowError>> + Send + 'async_trait>>

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

Execute the flow once.