[][src]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.

Loading content...

Implementors

impl<Ii> Pipeline<<Ii as IntoIterator>::IntoIter> for Ii where
    Ii: IntoIterator,
    Ii::IntoIter: Send + 'static,
    Ii::Item: Send + 'static, 
[src]

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

Loading content...