concurrent-machines: Concurrent networked stream transducers

[ bsd3, concurrency, control, library ] [ Propose Tags ]

A simple use-case for this library is to run the stages of a pipelined streaming computation concurrently. If data is streaming through multiple processing stages, you might build a machine like

step1 >~> step2 >~> step3

The >~> operator connects the machines on either side with a one-element buffer. This means that data is pulled from upstream sources eagerly (perhaps pulling one more value than will be consumed by downstream), but it also means that each stage can be working simultaneously, increasing throughput of the entire pipeline.

A few small examples are available in the examples directory of the source repository.

Downloads

Maintainer's Corner

Package maintainers

For package maintainers and hackage trustees

Candidates

  • No Candidates
Versions [RSS] 0.1.0.0, 0.1.0.1, 0.1.0.2, 0.2.0, 0.2.1, 0.2.3, 0.2.3.1, 0.2.3.2, 0.2.3.3, 0.3.0, 0.3.1, 0.3.1.1, 0.3.1.2, 0.3.1.3, 0.3.1.4, 0.3.1.5
Dependencies async (>=2.0.1 && <2.1), base (>=4.6 && <5), containers (>=0.5 && <0.6), lifted-async (>=0.1 && <0.8), machines (>=0.5 && <0.6), monad-control (>=1.0 && <1.1), semigroups (>=0.8 && <0.17), time (>=1.4 && <1.6), transformers (>=0.4 && <0.5), transformers-base (>=0.4 && <0.5) [details]
License BSD-3-Clause
Copyright Copyright (C) 2014 Anthony Cowley
Author Anthony Cowley
Maintainer acowley@gmail.com
Category Concurrency, Control
Source repo head: git clone http://github.com/acowley/concurrent-machines.git
Uploaded by AnthonyCowley at 2015-06-23T00:39:01Z
Distributions NixOS:0.3.1.5
Reverse Dependencies 3 direct, 1 indirect [details]
Downloads 9123 total (41 in the last 30 days)
Rating (no votes yet) [estimated by Bayesian average]
Your Rating
  • λ
  • λ
  • λ
Status Docs uploaded by user
Build status unknown [no reports yet]