Time Bufferizing using core.async in Clojure

time-bufferize.clj

(defn time-bufferize [in t]
  (let [c (chan)]
    (go
      (loop
        [buf []
         timer (timeout t)]

        (let [[value port] (alts! [in timer])
              timed-out (= port timer) ]
          (if (= port timer) ; timed out
            (do
              (>! c buf)
              (recur [] (timeout t)))

            (recur (conj buf value) timer)))))
    c))