Make a concurrent pipe using a fold and a stream

[harendra-kumar]

Create a fold/scan and a stream sharing a concurrency channel such that if you run the fold the results appear in the stream. We can generalize this to one fold connected to n streams. Config options can be used to have a blocking behavior for the fold if any receiver buffer becomes full or ignore the overflow etc.