Struct PipelineBuilder 

pub struct PipelineBuilder<S> { /* private fields */ }

A utility for assembling Step implementations into a linear chain.

Implementations

impl<S> PipelineBuilder<S>

where S: Step,

pub fn add_stage<A>(self, action: A) -> PipelineBuilder<PipelineStep<S, A>>

where A: Step<Input = S::Output>,

Appends a new stage to the end of the current pipeline.

pub fn add_map<F, O>( self, f: F, ) -> PipelineBuilder<PipelineStep<S, ClosureStep<F, S::Output, O>>>

where F: Fn(S::Output) -> Result<O, PipelineError>,

Appends a closure-based transformation to the pipeline.

pub fn build(self) -> Pipeline<impl Step<Input = S::Input, Output = S::Output>>

Seals the pipeline and returns a runnable Pipeline instance.

This finalizes the internal recursive structure and adds a termination node.