lawless-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.
NOTE: This is a temporary fork until concurrent-machines 0.3.1 is released.
[Skip to Readme]
Modules
[Index]
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
- lawless-concurrent-machines-0.3.1.tar.gz [browse] (Cabal source package)
- Package description (as included in the package)
Maintainer's Corner
For package maintainers and hackage trustees
Candidates
Versions [RSS] | 0.3.1 |
---|---|
Change log | CHANGELOG.md |
Dependencies | async (>=2.0.1 && <2.2), base (>=4.8 && <5), containers (>=0.5 && <0.6), lifted-async (>=0.1 && <0.10), machines (>=0.5 && <0.7), monad-control (>=1.0 && <1.1), semigroups (>=0.8 && <0.19), time (>=1.4 && <1.9), transformers (>=0.4 && <0.6), transformers-base (>=0.4 && <0.6) [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 git@gitlab.com:theunixman/haskell/lawless-concurrent-machines.git |
Uploaded | by misandrist at 2017-10-02T04:29:45Z |
Distributions | |
Reverse Dependencies | 1 direct, 2 indirect [details] |
Downloads | 948 total (2 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] |