streaming-concurrency alternatives and similar packages
Based on the "streaming" category.
Alternatively, view streaming-concurrency alternatives based on common mentions on social networks and blogs.
Common lower-level functions needed by various streaming data libraries
Bidirectional support between the streaming and conduit libraries
Cassava support for the streaming library
with/bracket-style idioms for use with streaming
Do you think we are missing an alternative of streaming-concurrency or a related project?
Concurrency for the streaming ecosystem
There are two primary higher-level use-cases for this library:
Stream-based equivalent to [
parMap] (albeit utilising concurrency rather than true parallelism).
However, low-level functions are also exposed so you can construct
your own methods of concurrently using
Streams (and there are also
Stream-specific functions if you wish to use it with other data
Conceptually, the approach taken is to consider a typical
correspondence system with an in-basket/tray for receiving messages
for others, and an out-basket/tray to be later dealt with. Inputs are
thus provided into the
InBasket and removed once available from the
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
spawn primitive, thus not requiring explicit garbage
Another main difference is that the naming of the
types has been switched around: pipes-concurrency seems to consider
them from the point of view of the supplying/consuming
whereas here they are considered from the point of view of the