Do we want a channel-based parallel processor?

[sudhirj]

I've written https://github.com/sudhirj/cirque

It basically takes a processing function and gives you an input and output channel, and inputs sent to the input channel and processed in parallel with the results sent in order on the output channel. Very similar to Stream but off a channel API.

If we want to roll this into conc and based it off Stream I can raise a PR.