Trait pipeliner::Pipeline

pub trait Pipeline<I>where
    I: Iterator + Send + 'static,
    I::Item: Send + 'static,{
    fn with_threads(self, num_threads: usize) -> PipelineBuilder<I>;
}

Things which implement this can be used with the Pipeliner library.

Required Methods

fn with_threads(self, num_threads: usize) -> PipelineBuilder<I>

Returns an PipelineBuilder that will execute using this many threads, and 0 buffering.

Implementors

impl<Ii> Pipeline<<Ii as IntoIterator>::IntoIter> for Iiwhere
    Ii: IntoIterator,
    Ii::IntoIter: Send + 'static,
    Ii::Item: Send + 'static,

IntoIterators (and Iterators!) can be used as a Pipeline.