Efficient way of connecting disparate streams
When you want to connect several disparate pipes in a configuration driven way use this tool. Disparate here means pipes that at the end should buffer completely.
a => b => c wait for c to end then c => d => e wait for e to end then e => f => g
Create a config and pass it in to pipline.
var pipeline =pipes:JSONStreampipes:JSONStreamJSONStreampipes:JSONStream;
Pipeline exposes the 'in' stream and 'out' stream through two properties.
The above will break because pipeline.out in the above example is objects. but add in another JSONStream.stringify and you will have a working pipeline.
Pipelines are executed in the array order they are provided.
Please look at the Test file for examples.