Trait ppipe::PPipe [−] [src]

pub trait PPipe: Iterator {
    fn ppipe(self, back_pressure: Option<usize>) -> IntoIter<Self::Item>;
}

This trait does all the work for you so that generally every iterator you use has the ppipe method. Make sure to include this trait for it to take effect:

extern crate ppipe;
use ppipe::*;

Required Methods

This method can be called on generally any iterator, making every previous task become part of a concurrent pipeline.

ppipe takes an Option<usize> parameter which can be used to declare if you want back-pressure or not. ppipe(Some(1000)) would mean that you want the concurrent receiver to hold no more than 1000 values and tell the sender to block until the receiver's buffer goes below 1000 over the course of, for example, a for loop.

Implementors