Struct ConcurrentWorkflow 

pub struct ConcurrentWorkflow { /* private fields */ }

Concurrent workflow: all registered agents execute in parallel; results are merged via a merge function.

Example

use echo_core::agent::{Agent, AgentEvent};
use echo_core::error::Result;
use echo_orchestration::workflow::{ConcurrentWorkflow, Workflow};
use futures::future::BoxFuture;
use futures::stream::{self, BoxStream};


let agent_x = DummyAgent::new("tech");
let agent_y = DummyAgent::new("business");

let mut wf = ConcurrentWorkflow::builder()
    .agent(agent_x)
    .agent(agent_y)
    .merge(|results| {
        format!("Combined analysis:\n{}", results.join("\n\n"))
    })
    .build();

let output = wf.run("Analyze AI Agent development trends").await?;
println!("{}", output.result);

Implementations

impl ConcurrentWorkflow

pub fn builder() -> ConcurrentWorkflowBuilder

Trait Implementations

impl Workflow for ConcurrentWorkflow

fn run<'a>( &'a mut self, input: &'a str, ) -> Pin<Box<dyn Future<Output = Result<WorkflowOutput, ReactError>> + Send + 'a>>

Run the entire workflow with input as the initial input

fn run_stream<'a>( &'a mut self, input: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<WorkflowEvent, ReactError>> + Send + 'a>>, ReactError>> + Send + 'a>>

Run the entire workflow with input as initial input (streaming per-node events).