Fork me on GitHub

@mpuppe: @hiredman is spot on; in addition to passing three channels to each go-loop, you can collect all error-channels into a “global-error-chan”, using the async/mix and async/admix primitives.


In addition to passing three channels, I also recommend passing an optional, fourth—finalize channel. If your pipelines deal with external resources, you might want to cleanup before closing the channel.


Is it possible to get the transducer in this gist to "produce zero or more outputs per input" as described in async/pipeline doc ? I would like the last expression to return only one map instead of a list of 3 maps.


thank you it's exactly what I needed