csp.clj

(ns csp.core
  (:require [clojure.core.async :as async
             :refer [chan go >! <! <!! timeout pub sub]])
  (:require [clojure.pprint :refer [pprint]])
  (:gen-class))


(def c (chan))
(def p (pub c (fn [[tag & _]] tag)))

(def c1 (sub p :baz (chan)))
(def c2 (sub p :baz (chan)))
(def c3 (sub p :baz (chan)))

(defn -main [& args]
  (go
   (let [v (<! c1)]
     (println "c1" v)))
  (go
   (let [v (<! c2)]
     (println "c2" v)))
  (go
   (println "waiting...")
   (<! (async/merge [c1]))
   (let [v (<! c3)]
     (println "c3" v)))
  
  (println "starting")
  (go
   (>! c [:baz 1 2 3]))
  
  (<!! (go (<! (timeout 10000)))))

Output:

% lein run
starting
waiting...
c2 c1 [[:baz :baz 1 2 13 ]2 
3]