funil a stream that aggegates other streams var Funil = require('./funil'); var f = new Funil();f.add(streamA);f.add(streamB);f.add(streamC);f.add(streamD); f.on('data', function(d) { /* d can be from either one of the streams */ });