shaunxcode

(require '[clojure.core.async :as ca])

(def some-ch (ca/chan))
(def result-ch (ca/reduce 
                 (fn [xs msg] 
                   (if (= msg :done)                     
                     (reduced xs)
                     (conj xs msg)))
                   []
                   some-ch))