co-process
Concurrent producer/consumer processing for co with optional concurrency control.
Also see co-thread for a more lightweight but buffering implementation.
Example
var co = ;var process = ; ;
API
process(producer, consumer)
Let consumer
concurrently process work from producer
.
Whenever producer
yields data - and maximum concurrency isn't reached - it will be read immediately. Stop processing by yielding a falsy value.
Options:
- max: limit maximum concurrency
- timeout: kill workers after x milliseconds (default: 100)
Debugging
Set or add co-process
to the DEBUG
env variable to see how workers spawn, die and consume work.
Installation
$ npm install co-process
License
MIT