Struct pipelines::Multiplex

pub struct Multiplex<In, Out, Entry> where
    Entry: PipelineEntry<In, Out> + Send,  { /* fields omitted */ }

A meta pipeline entry that distributes the work of a PipelineEntry across multiple threads

Methods

impl<In, Out, Entry> Multiplex<In, Out, Entry> where
    Entry: PipelineEntry<In, Out> + Send + Copy, 

Build a Multiplex by copying an existing PipelineEntry

Note: this is only applicable where the PipelineEntry implements Copy, which due to Rust #28229 is not true of closures

fn from(entry: Entry, workers: usize) -> Self

impl<In, Out, Entry> Multiplex<In, Out, Entry> where
    Entry: PipelineEntry<In, Out> + Send, 

fn new(entries: Vec<Entry>) -> Self

Trait Implementations

impl<In: Debug, Out: Debug, Entry: Debug> Debug for Multiplex<In, Out, Entry> where
    Entry: PipelineEntry<In, Out> + Send, 

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

Formats the value using the given formatter.

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, 

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