Struct pipeliner::PipelineBuilder
[−]
[src]
pub struct PipelineBuilder<It: Iterator<Item = In>, In: Send + 'static> { /* fields omitted */ }
This is an intermediate data structure which allows you to configure how your pipeline should run.
Methods
impl<It, In> PipelineBuilder<It, In> where
It: Iterator<Item = In> + Send + 'static,
In: Send + 'static, [src]
It: Iterator<Item = In> + Send + 'static,
In: Send + 'static,
fn num_threads(self, num_threads: usize) -> Self
Set how many worker threads should be used to perform this work. A value of 0 is interpreted as 1.
fn out_buffer(self, size: usize) -> Self
Set how many output values to cache. The default, 0, results in synchronous output. Note that in effect each thread caches its output as it waits to send it, so in many cases you may not need additional output buffering.
fn map<F, Out>(self, callable: F) -> PipelineIter<Result<Out, ()>> where
Out: Send + 'static,
F: Fn(In) -> Out + Send + Sync + 'static,
Out: Send + 'static,
F: Fn(In) -> Out + Send + Sync + 'static,
Perform work on the input, and make the results available via the PipelineIterator.
Note that unlike in Iterators, this map does not preserve the ordering of the input.
This allows results to be consumed as soon as they become available.