streaming-concurrency: Concurrency support for the streaming ecosystem

[ data, library, mit, streaming ] [ Propose Tags ]
This version is deprecated.

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.


[Skip to Readme]

Downloads

Maintainer's Corner

Package maintainers

For package maintainers and hackage trustees

Candidates

Versions [RSS] 0.1.0.0, 0.2.0.0, 0.3.0.0, 0.3.0.1, 0.3.1.0, 0.3.1.1, 0.3.1.2, 0.3.1.3 (info)
Change log ChangeLog.md
Dependencies base (>=4 && <5), bytestring, exceptions (>=0.6 && <0.9), lifted-async (>=0.9.1 && <0.10), monad-control (>=1 && <2), stm (>=2.4 && <3), streaming (>=0.1.4.0 && <0.2), streaming-bytestring (>=0.1.4.5 && <0.2), streaming-with (>=0.1 && <0.2), transformers-base [details]
License MIT
Copyright Ivan Lazar Miljenovic
Author Ivan Lazar Miljenovic
Maintainer Ivan.Miljenovic@gmail.com
Category Data
Source repo head: git clone https://github.com/ivan-m/streaming-concurrency.git
Uploaded by IvanMiljenovic at 2017-07-05T02:15:10Z
Distributions
Reverse Dependencies 1 direct, 1 indirect [details]
Downloads 4160 total (25 in the last 30 days)
Rating (no votes yet) [estimated by Bayesian average]
Your Rating
  • λ
  • λ
  • λ
Status Docs available [build log]
Last success reported on 2017-07-05 [all 1 reports]

Readme for streaming-concurrency-0.2.0.0

[back to package description]

streaming-concurrency

Hackage Build Status

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.