seque implemented with core.async

seque_async.clj

(defn seque
  [n s]
  (let [ch (async/chan n)]
    (async/go-loop [s s]
      (try
        (if-let [[x & xs] (seq s)]
          (do (async/>! ch (list x))
              (recur xs))
          (async/close! ch))
        (catch Throwable t
          (async/>! ch t)
          (async/close! ch))))
    ((fn f []
       (lazy-seq
        (if-let [x (async/<!! ch)]
          (if (instance? Throwable x)
            (throw x)
            (cons (first x) (f)))
          ()))))))