concurrent-machines: Concurrent networked stream transducers
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.
Modules
[Index]
Downloads
- concurrent-machines-0.1.0.0.tar.gz [browse] (Cabal source package)
- Package description (as included in the package)
Maintainer's Corner
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 | 9513 total (47 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] |