A simple way to create a Node.JS Transform stream which processes in parallel. You can limit the concurrency (default is 16) and order is not preserved (so chunks/objects can end up in a different order to the order they started in if the transform functions take different amounts of time).
Built using through2 and has the
same API with the addition of a
objectMode streams are supported for completeness but I'm not
sure they'd be useful for anything.
npm install --save through2-concurrent
Process lines from a CSV in paralel. The order the results end up in
all variable is not deterministic.
var through2Concurrent = ;var all = ;fs