How I learned core.async

copper.clj

(ns otfrom.copper
  (:require [clojure.core.async :as a]))

(def tenner (a/chan))
(def mten (a/mult tenner))

(def t1 (a/tap mten (a/chan)))

(def t2 (a/tap mten (a/chan)))

(def r1 (a/reduce (fn [a n]
                    (println "r1 a: " a " n: " n)
                    (+ a n))
                  0
                  t1))
(def r2 (a/reduce (fn [a n]
                    (println "r2 a: " a " n: " n)
                    (* a (inc n)))
                  1
                  t2))

(a/pipe (a/to-chan (range 10)) tenner)

(a/<!! r1)
(a/<!! r2)