Trait PipelineEntry

pub trait PipelineEntry<In, Out> {
    // Required method
    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)

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

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,

impl<In, Out, Func> PipelineEntry<In, Out> for Mapper<In, Out, Func>

where Func: Fn(In) -> Out,