Skip to content

Instantly share code, notes, and snippets.

Created Jun 21, 2015
What would you like to do?
(let [channel (create)
incremented-values (map* inc channel)
decremented-values (map* dec channel)]
(consume incremented-values (fn [i] (println "Incremented value: " i)))
(consume decremented-values (fn [i] (println "Decremented value: " i)))
(accept channel 1)
(accept channel 2)
(accept channel 3)
(ms/flush channel))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment