Struct pipelines::Filter

pub struct Filter<In, Func> where
    Func: Fn(&In) -> bool,  { /* fields omitted */ }

A pipeline entry with a predicate that values must beet to be sent further in the pipeline

Methods

impl<In, Func> Filter<In, Func> where
    Func: Fn(&In) -> bool, 

Make a new Filter out of a predicate function

fn new(func: Func) -> Self

Trait Implementations

impl<In: Debug, Func: Debug> Debug for Filter<In, Func> where
    Func: Fn(&In) -> bool, 

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<In, Func> PipelineEntry<In, In> for Filter<In, Func> where
    Func: Fn(&In) -> bool, 

fn process<I: IntoIterator<Item = In>>(self, tx: Sender<In>, rx: I)