streaming-concurrency

Concurrency for the streaming ecosystem

The primary purpose for this library is to be able to merge multiple Streams together. However, it is possible to build higher abstractions on top of this to be able to also feed multiple streams.

Thanks and recognition

The code here is heavily based upon -- and borrows the underlying Buffer code from -- Gabriel Gonzalez's pipes-concurrency. It differs from it primarily in being more bracket-oriented rather than providing a spawn primitive, thus not requiring explicit garbage collection.