Struct PipelineBuilder 

pub struct PipelineBuilder<T: Sync + Send + 'static> {
    pub(crate) rx: Receiver<T>,
    pub(crate) threads: Vec<JoinHandle<()>>,
}

Fields

rx: Receiver<T>

threads: Vec<JoinHandle<()>>

Implementations

impl<T: Sync + Send + 'static> PipelineBuilder<T>

pub fn new<C>(c: C) -> Self

where C: FnMut() -> Result<T, Box<dyn Error>> + Send + 'static,

Trait Implementations

impl<T: Sync + Send + 'static> PipelineLayer<T> for PipelineBuilder<T>

fn to<R: Sync + Send + 'static, C>(self, c: C) -> impl PipelineLayer<R>

where C: Fn(T) -> Result<R, Box<dyn Error>> + Sync + Send + 'static,

fn map_to<R: Sync + Send + 'static, C>(self, c: C) -> impl PipelineLayer<R>

where C: Fn(T) -> Vec<R> + Sync + Send + 'static,

fn finish<C>(self, c: C) -> Vec<JoinHandle<()>>

where C: FnMut(T) -> Result<(), Box<dyn Error>> + Send + 'static,