xtream



stream2 helpers, inspired by rvagg/through2 and its friends

TL;DL

$3

* xtream.through(streamOptions, transform, flush)
* xtream.map(streamOptions, mapCallback)
* xtream.reduce(streamOptions, reduceCallback, initial)
* xtream.filter(streamOptions, filterCallback)

Transform stream helpers that mimick the Array operations.

$3

* xtream.inspect(streamOptions, inspectCallback)

Do nothing but emit every read data to inspectCallback

$3

* xtream.duplex(streamOptions, readableStream, writableStream)

Generate a duplex stream that write to writableStream, read from readableStream

$3

* xtream.split(streamOptions, spliter, mapCallback);

Split emitted data using spliter. Optional mapCallback can be assigned to process each splited result.

$3

* xtream.concat(completeCallback)

Collect all readable contents into the completeCallback.

$3

* xtream.combine(fisrtStream, secondStream, thirdStream, ..., lastStream);

Generate a stream pipeline; Write to the first stream, read from last stream and each stream is piped to the next in line.

References

* http://codewinds.com/blog/2013-08-31-nodejs-duplex-streams.html
* https://github.com/substack/stream-handbook
* http://codyaray.com/2013/04/intro-to-streams2-new-node-streams-part-1