brief-example.js

var through = require('through2');
var multi = require('multi-read-stream');
var pumpify = require('pumpify');
var pump = require('pump');

function doer() {
  var rs = multi.obj();
  
  creator.on('stream', function(s) {
    rs.add(pumpify.obj(s, aTransformStream))
  });
  
  rs.add(pumpify.obj(someReadableStream, aTransformStream))
  return rs
}

pump([doer(), anotherTransform, sinkStream], function(err) {
  if (err) {
    console.log("An error happened :( : ", err);
  }
})