src/lib/pipeline.js
/**
 * Compose stream transformers in parallel.
 */
Compose stream transformers in parallel.
Compose stream transformers in parallel .
function multiplex(xfes) {
  return stream => {
    const streams = xfes.map(xf => xf(stream));
    return event => {
      streams.map(stream => forward(stream, event));
    };
  };
}
function multiplex ( xfes ) { return stream => { const streams = xfes . map ( xf => xf ( stream ) ) ; return event => { streams . map ( stream => forward ( stream , event ) ) ; } ; } ; }
Compose stream transformers in parallel.
Compose stream transformers in parallel .