Struct SimqBuilder 

pub struct SimqBuilder<A, B> { /* private fields */ }

Job Builder

Implementations

impl<A: Send + 'static, B: Send + 'static> SimqBuilder<A, B>

pub fn register(max_threads: usize, func: fn(A) -> B) -> Self

Register a job, designating the maximum number of parallel threads you wish to run the task

pub fn and_then(self, and_then: fn(&B)) -> Self

CANNOT BE USED IN CONJUNCTION WITH and_then_mut

After producing a result, do something with the result This is good for additional work, like logging or storing to a database

pub fn and_then_mut(self, and_then_mut: fn(&mut B)) -> Self

CANNOT BE USED IN CONJUNCTION WITH and_then

After producing a result, do something with the result (mutable) Same as the and_then callback, but if you need a mutable reference for some reason

pub fn spawn(self) -> SimqChannel<A, B>

Launch the worker The worker will continue accepting and processing data as long as the WorkerChannel is not dropped.