tbatchelli

(ns sieve.core
  (:require [clojure.core.async :as async :refer :all]]))

(defn counter-stream [n]
  (let [c (chan)]
    (go
     (loop [i n]
       (>! c i)
       (recur (inc i))))
    c))