concurrent-machines

Version 0.3.1.1 revision 0 uploaded 2018-01-27T04:07:56.000Z by AnthonyCowley.

Package meta

Synopsis

Concurrent networked stream transducers

Description

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.

Author

Anthony Cowley

Bug reports

n/a

Category

Concurrency, Control

Copyright

Copyright (C) 2014 Anthony Cowley

Homepage

n/a

Maintainer

acowley@gmail.com

Package URL

n/a

Stability

n/a

Components

• lib:concurrent-machines
• bench:fanout
• test:splotime
• test:tests