Function eventio::split

pub fn split<D, A, I, O, F, S, R>(
    data_rx: Receiver<D>, 
    ack_tx: Sender<A>, 
    initialize: I, 
    fold: O, 
    finalize: F, 
    nthreads: usize
) -> Vec<JoinHandle<R>> where
    D: 'static + Send + Event,
    <D as Event>::Ack: Into<A>,
    A: 'static + Send,
    I: 'static + Fn() -> S + Copy + Send,
    O: 'static + Fn(S, &D) -> S + Copy + Send,
    F: 'static + Fn(S) -> R + Copy + Send,
    R: 'static + Send, 

Spawns worker threads to process events in parallel.