Struct Pipeline 

pub struct Pipeline<T> { /* private fields */ }

Named transforms run in order: each stage gets the previous one’s output.

Implementations

impl<T> Pipeline<T>

pub fn new() -> Self

pub fn then( self, name: impl Into<String>, transform: impl Transform<T> + 'static, ) -> Self

Add a stage at the end.

pub fn push( &mut self, name: impl Into<String>, transform: Box<dyn Transform<T>>, )

Add a boxed stage at the end.

pub fn names(&self) -> Vec<&str>

The stages’ names, in order.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn apply(&self, input: T) -> Result<T, PipelineError>

Run every stage in order.

Trait Implementations

impl<T> Debug for Pipeline<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for Pipeline<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Transform<T> for Pipeline<T>

A pipeline is itself a transform, so pipelines nest.

fn apply(&self, input: T) -> Result<T, TransformError>