chan->lazy-seq

chan->lazy-seq.clj

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

(def c (a/chan 10))

(a/go
 (loop [i 0]
   (println "putting" i)
   (a/>! c i)
   (if (< i 100)
     (recur (inc i))
     (a/close! c))))

(defn chan->seq [chan]
  (let [p (promise)]
    (a/take! chan #(deliver p %))
    (when @p
      (cons @p (lazy-seq (chan->seq chan))))))