@hackage concurrent-machines0.1.0.2
Concurrent networked stream transducers
Categories
License
BSD-3-Clause
Maintainer
acowley@gmail.com
Links
Versions
Installation
Dependencies (10)
- 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 Show all…
Dependents (4)
@hackage/machines-amazonka, @hackage/liblawless, @hackage/libmolude, @hackage/eventlog-live
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.