clojure core.async pub/sub

gistfile1.clj

;create our publisher
(def pub-ch (chan))
(def publication (pub pub-ch #(:topic %)))

;sub chans
(def sub-1 (chan))
(def sub-2 (chan))

;subscribe subs to publisher
(sub publication "clojure" sub-1)
(sub publication "clojure" sub-2)

;start the sub loops
(go (while true (println "got on sub-1:: " (<! sub-1))))
(go (while true (println "got on sub-2:: " (<! sub-2))))

;publish
(>!! pub-ch {:topic "clojure" :k-1 "hello" })