Trait PipelineMap 

pub trait PipelineMap<I, M>
where
    I: Iterator,
    I::Item: Send + 'static,
    M: Mapper<I::Item> + Clone + Send + 'static,
    M::Out: Send + 'static,
{
    // Required method
    fn plmap(self, n_workers: usize, m: M) -> Pipeline<I, M> ;
}

PipelineMap can be imported to add the plmap function to iterators.

Required Methods

fn plmap(self, n_workers: usize, m: M) -> Pipeline<I, M>

Implementors

impl<I, M> PipelineMap<I, M> for I

where I: Iterator, <I as Iterator>::Item: Send + 'static, M: Mapper<I::Item> + Clone + Send + 'static, <M as Mapper<I::Item>>::Out: Send + 'static,