Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
(def c1 (chan))
(def c2 (chan))
(def xf (map #(repeat 3 %)))
(a/pipeline 4 c2 xf c1)
(a/put! c1 {:name "hello"})
(<!! c2)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment