clojure.core.async/mult

View this page on ClojureDocs

Type: function Added: Clojure unknown Examples: 2 Runnable: 0

([ch])

Creates and returns a mult(iple) of the supplied channel. Channels containing copies of the channel can be created with 'tap', and detached with 'untap'.

Each item is distributed to all taps in parallel and synchronously, i.e. each tap must accept before the next item is distributed. Use buffering/windowing to prevent slow taps from holding up the mult.

Items received when there are no taps get dropped.

If a tap puts to a closed channel, it will be removed from the mult.

Examples

by runexec on 2014-10-01 . May have evaluation errors. ▶

(def sz 20) #'user/sz (def c (chan sz)) #'user/c (def mult-c (mult c)) #'user/mult-c (def cx (chan sz)) #'user/cx (def cy (chan sz)) #'user/cy (def cz (chan sz)) #'user/cz (tap mult-c cx) #<ManyToManyChannel clojure.core.async.impl.channels.ManyToManyChannel@63942268> (tap mult-c cy) #<ManyToManyChannel clojure.core.async.impl.channels.ManyToManyChannel@1f025346> (tap mult-c cz) #<ManyToManyChannel clojure.core.async.impl.channels.ManyToManyChannel@29d4cd91> (put! c "sent to all") true (<!! cx) "sent to all" (<!! cy) "sent to all" (<!! cz) "sent to all"

by cuneoPauloCesar on 2015-10-31 . May have evaluation errors. ▶

;; Dont read from the source of mult, or you'll get read race contention (def a (chan)) (def m (mult a)) (def b (chan)) (tap m b) (go-loop [] (when-let [v (<! b)] (do (println "b got" v) (recur)))) ;; next line is pain self inflicted (go-loop [] (when-let [v (<! a)] (do (println "a(source) got" v) (recur)))) (put! a "Hello ") b got Hello (put! a " World") a(source) got World

See also

• clojure.core.async/tap
• clojure.core.async/untap
• clojure.core.async/mix

---

Content from the matching ClojureDocs page, with authors credited on each contribution.