This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2016-09-30
Channels
- # bangalore-clj (1)
- # beginners (9)
- # boot (51)
- # cider (20)
- # cljs-dev (419)
- # clojars (1)
- # clojure (338)
- # clojure-brasil (64)
- # clojure-dev (7)
- # clojure-greece (2)
- # clojure-italy (3)
- # clojure-russia (10)
- # clojure-spec (127)
- # clojure-uk (12)
- # clojurebridge (2)
- # clojurescript (132)
- # core-async (8)
- # cursive (37)
- # datomic (34)
- # dirac (5)
- # events (1)
- # funcool (3)
- # hoplon (39)
- # jobs (3)
- # leiningen (3)
- # off-topic (16)
- # om (44)
- # onyx (7)
- # pedestal (20)
- # protorepl (1)
- # random (1)
- # re-frame (64)
- # reagent (6)
- # specter (4)
- # test-check (9)
- # untangled (17)
- # vim (4)
Is there a way to combine multiple core.async channels, but take all from the first until it is closed, then all from the second, e.t.c.?
Essentially a concat
but on channels instead of a lazy seq
I have
(vec (concat
(<! (async/into [] schedule-ch))
(<! (async/into [] cp-ch))
(<! (async/into [] c-ch))))
which works but feels inelegantwell, that could be simplified with a plain old reduce over a vector of channels
(reduce #(into % (<! (async/into [] %2)) [] [schedule-ch cp-ch c-ch])