Fork me on GitHub
#core-async
<
2016-08-10
>
pre04:08:59

@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.

pre04:08:16

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.

yenda09:08:39

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. https://gist.github.com/yenda/2ba5c2d9d3f588e4b08e157edb8ccfa8

alexmiller13:08:07

mapcat instead of map?

yenda13:08:00

thank you it's exactly what I needed