stream-combiner2

This is a sequel to stream-combiner for streams3.

1var combine = require('stream-combiner2')

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.

Streams1 streams are automatically upgraded to be streams3 streams.

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 = inspect(JSON.parse(data))  // render it nicely
9    callback(null, repr)
10  }),
11  process.stdout                          // pipe it to stdout !
12)

License

MIT