Function cue::pipeline

pub fn pipeline<Q, R, QF, JF, W>(
    name: &str, 
    num_workers: usize, 
    work: W, 
    worker: QF, 
    joiner: JF
) where
    Q: Send + Sized,
    R: Send + Sized,
    QF: Fn(Q) -> R + Sync,
    JF: FnMut(R) + Send + Sync,
    W: Iterator<Item = Q>,