Trait pipelines::PipelineEntry

pub trait PipelineEntry<In, Out> {
    fn process<I: IntoIterator<Item = In>>(self, tx: Sender<Out>, rx: I);
}

A trait for structs that may be used as Pipeline entries

Required Methods

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

Implementors

• impl<In, Out, Func> PipelineEntry<In, Out> for Mapper<In, Out, Func> where
    Func: Fn(In) -> Out, 
• impl<In, Func> PipelineEntry<In, In> for Filter<In, Func> where
    Func: Fn(&In) -> bool, 
• impl<In, Out, Entry> PipelineEntry<In, Out> for Multiplex<In, Out, Entry> where
    Entry: PipelineEntry<In, Out> + Send + 'static,
    In: Send + 'static,
    Out: Send + 'static,