stream-combiner

Combine (stream1,...,streamN)

Turn a pipeline into a single stream. Combine returns a stream that writes to the first stream and reads from the last stream.

Listening for 'error' will recieve errors from all streams inside the pipe.

1var Combine = require('stream-combiner')
2var es      = require('event-stream')
3
4Combine(                                  // connect streams together with `pipe`
5  process.openStdin(),                    // open stdin
6  es.split(),                             // split stream to break on newlines
7  es.map(function (data, callback) {      // turn this async function into a stream
8    var repr = util.inspect(JSON.parse(data))  // render it nicely
9    callback(null, repr)
10  }),
11  process.stdout                          // pipe it to stdout !
12)

Can also be called with an array:

1var combinedStream = Combine([
2  stream1,
3  stream2,
4]);

Or to combine gulp plugins:

1function coffeePipe() {
2  return Combine(
3    coffeescript(),
4    coffeelint.reporter('fail').on('error', function(){
5      gutil.beep()
6      gulp.run('lint')
7    })
8}
9
10//usage:
11gulp.src().pipe(coffeePipe());

License

MIT