Core.async `mult` example

mult_example.clj

(require '[clojure.core.async :refer [chan timeout >!! <!! alts!! mult tap]])

(defn td [ch]
  (first (alts!! [ch (timeout 100)])))


(def c (chan 10))


(>!! c :foo) ; true
(>!! c :bar) ; true


(td c) ; :foo
(td c) ; :bar

(def m (mult c))

(>!! c :after) ; true
(>!! c :again) ; true

(td c) ; nil

(def t (chan 10))

(tap m t)

(>!! c :more) ; true


(td c) ; nil
(td t) ; :more