This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2016-08-10
Channels
- # admin-announcements (1)
- # alda (1)
- # bangalore-clj (1)
- # beginners (94)
- # boot (139)
- # braveandtrue (1)
- # cider (19)
- # cljs-dev (21)
- # cljsjs (8)
- # cljsrn (79)
- # clojure (124)
- # clojure-austin (1)
- # clojure-belgium (1)
- # clojure-berlin (3)
- # clojure-hamburg (3)
- # clojure-quebec (1)
- # clojure-russia (77)
- # clojure-spec (5)
- # clojure-uk (18)
- # clojurescript (39)
- # conf-proposals (21)
- # core-async (5)
- # cursive (8)
- # datomic (40)
- # defnpodcast (1)
- # devcards (14)
- # dirac (5)
- # editors (1)
- # emacs (4)
- # jobs (1)
- # liberator (4)
- # onyx (29)
- # perun (15)
- # proton (15)
- # protorepl (9)
- # re-frame (47)
- # reagent (38)
- # ring (1)
- # rum (7)
- # specter (23)
- # untangled (8)
- # yada (55)
@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. https://gist.github.com/yenda/2ba5c2d9d3f588e4b08e157edb8ccfa8
mapcat instead of map?