不进行分块的“序列”版本

Question

我想要一个不分块 32 个元素的 sequence 版本。目前，此代码将输出

(def peek #(doto % (print " ")))
(def pause #(do (Thread/sleep 10)
                %))

(take 2 (->> (range 100)
             (sequence (comp (map peek)
                             (map pause)
                             (map inc)))))

;; prints 0 1 2 3 4 <..etc..> 32
;; => (0, 1)

我想要它的一个版本，以便它只遍历它需要的元素

(take 2 (->> (range 100)
             (iter-sequence  (comp (map peek)
                             (map pause)
                             (map inc)))))

;; prints 0 1
;; => (0, 1)

有没有办法做到这一点？

Answer 1

我必须更改一些东西才能使其正常工作。第一种是剪切和粘贴sequence 代码并将clojure.lang.RT/chunkIteratorSeq 替换为具有公开构造函数方法的clojure.lang.IteratorSeq 的替代版本。

原因是clojure.lang.IteratorSeq/create 对 L27 上的 iter.next() 进行了检查，如果源阻塞，它将阻塞。

(defn seqiter
  {:added "1.0"
   :static true}
  ([coll] coll)
  ([xform coll]
   (IteratorSeq.
    (TransformerIterator/create xform (clojure.lang.RT/iter coll))))
  ([xform coll & colls]
   (IteratorSeq.
    (TransformerIterator/createMulti
     xform
     (map #(clojure.lang.RT/iter %) (cons coll colls))))))