Struct ParallelFlow 

pub struct ParallelFlow<C: Callable> { /* private fields */ }

Parallel execution flow

Implementations

impl<C: Callable + 'static> ParallelFlow<C>

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

Create a new parallel flow

pub fn add_branch(self, callable: Arc<C>) -> Self

Add a branch

pub fn with_fan_out(self, strategy: FanOut) -> Self

Set fan-out strategy

pub fn with_fan_in(self, strategy: FanIn) -> Self

Set fan-in strategy

pub async fn execute(&self, input: &str) -> Vec<ParallelResult>

Execute all branches in parallel

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

Execute and aggregate results

pub fn name(&self) -> &str

Get the flow name

pub fn branch_count(&self) -> usize

Get branch count