clojure async channels

tea-async-test.clj

(ns async-tea-party.core
  (:require [clojure.core.async :as async])
  )

(def tea-channel (async/chan 10))

(async/>!! tea-channel :cup-of-tea)

(async/<!! tea-channel)

(async/>!! tea-channel :cup-of-tea-2)
(async/>!! tea-channel :cup-of-tea-3)
(async/>!! tea-channel :cup-of-tea-4)

(async/close! tea-channel)

(async/<!! tea-channel)
(async/<!! tea-channel)
(async/<!! tea-channel)
(async/<!! tea-channel)

;; async channel work

(let [tea-channel (async/chan)]
  (async/go (async/>! tea-channel :cup-of-tea-1))
  (async/go (println "Thanks for the " (async/<! tea-channel))))

(def tea-channel (async/chan 10))

(async/go-loop []
               (println "Thanks for the " (async/<! tea-channel))
               (recur))

(async/>!! tea-channel :hot-cup-of-tea)
(async/>!! tea-channel :mint-tea)



(def tea-channel (async/chan 10))
(def milk-channel (async/chan 10))
(def sugar-channel (async/chan 10))

(async/go-loop []
               (let [[v ch] (async/alts! [tea-channel
                                          milk-channel
                                          sugar-channel])]
                 (println "Got " v " from " ch)
                 (recur)))

(async/>!! tea-channel :cup-of-tea-1)
(async/>!! milk-channel :cup-of-milk-1)
(async/>!! sugar-channel :cup-of-sugar-1)