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.
[Skip to Readme]
Modules
[Index] [Quick Jump]
Flags
Manual Flags
Name | Description | Default |
---|---|---|
splot | Build test with splot visual output | Disabled |
Use -f <flag> to enable a flag, or -f -<flag> to disable that flag. More info
Downloads
- concurrent-machines-0.3.1.5.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 |
---|---|
Change log | CHANGELOG.md |
Dependencies | async (>=2.0.1 && <2.3), base (>=4.8 && <5), containers (>=0.5 && <0.7), lifted-async (>=0.1 && <0.11), machines (>=0.5 && <0.8), monad-control (>=1.0 && <1.1), semigroups (>=0.8 && <0.21), time (>=1.4 && <1.14), transformers (>=0.4 && <0.7), transformers-base (>=0.4 && <0.7) [details] |
Tested with | ghc ==8.6.5 || ==8.8.4 || ==8.10.7 || ==9.0.2 || ==9.2.1 |
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 2022-03-11T22:19:55Z |
Distributions | NixOS:0.3.1.5 |
Reverse Dependencies | 3 direct, 1 indirect [details] |
Downloads | 9773 total (26 in the last 30 days) |
Rating | (no votes yet) [estimated by Bayesian average] |
Your Rating | |
Status | Docs available [build log] Last success reported on 2022-03-12 [all 1 reports] |