Trait pipeliner::Pipeline

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

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

Required Methods

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

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

Implementors

• impl<Ii, It, In> Pipeline<It, In> for Ii where
    Ii: IntoIterator<Item = In, IntoIter = It>,
    It: Iterator<Item = In> + Send + 'static,
    In: Send + 'static,