Core.async issues are reported on Clojure's
JIRA: http://dev.clojure.org/jira/browse/ASYNC
pipeline does not have an incidental return value: it returns a channel
which closes when there are no more transformation results, i.e. when the
pipelining "process" is finished. There is no other way to
Since issue tracker for core.async is disabled on github, I'll spill this
here.
I think "pipeline" should return the "to" channel, to make it
threading-friendly:
(->> (range 100)
(a/to-chan)
(a/pipeline 10 (a/chan) (map inc))
(a/pipeline 2 (a/chan) (filter odd?)))
Currently
