Struct TransducerPipeline 

pub struct TransducerPipeline { /* private fields */ }

An ordered chain of TransducerSteps applied per element in one pass.

The composable core of the sequence organ’s map/filter/reduce surface: steps are fused so a source is traversed once, returning None for dropped elements.

Implementations

impl TransducerPipeline

pub fn new() -> Self

Start an empty pipeline.

pub fn map( self, mapper: Arc<dyn Fn(&mut Cx, Value) -> Result<Value> + Send + Sync + 'static>, ) -> Self

Append a mapping step, consuming and returning the pipeline.

pub fn filter( self, predicate: Arc<dyn Fn(&mut Cx, &Value) -> Result<bool> + Send + Sync + 'static>, ) -> Self

Append a filtering step, consuming and returning the pipeline.

pub fn apply(&self, cx: &mut Cx, value: Value) -> Result<Option<Value>>

Run one element through the pipeline.

Returns Some(value) if the element survives every step, or None if a filter step drops it.

Trait Implementations

impl Clone for TransducerPipeline

fn clone(&self) -> TransducerPipeline

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TransducerPipeline

fn default() -> TransducerPipeline

Returns the “default value” for a type.