Struct SequentialFlow 

pub struct SequentialFlow { /* private fields */ }

Ordered pipeline. Each step’s output is threaded as the next step’s input. Empty pipelines return their input unchanged (identity). First error short-circuits.

Implementations

impl SequentialFlow

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

New empty pipeline with the given name.

pub fn step(self, flow: Arc<dyn Flow>) -> Self

Append a step. Builder-style: returns self.

pub fn step_agent<A>(self, 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.

Equivalent to:

.step(std::sync::Arc::new(AgentFlow::new(agent)) as std::sync::Arc<dyn Flow>)

Trait Implementations

impl Flow for SequentialFlow

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.