src/lib/pipeline.js
/**
 * Forward an event to a stream.
 */
Forward an event to a stream.
Forward an event to a stream .
function forward(stream, event) {
  try {
    stream(event);
  } catch (reason) {
    errorLog(reason, 'warn');
  }
}
function forward ( stream , event ) { try { stream ( event ) ; } catch ( reason ) { errorLog ( reason , 'warn' ) ; } }
Forward an event to a stream.
Forward an event to a stream .