java - 如何在 Clojure 中使用 java.util.stream.Stream？

Question

(import java.nio.file.Files)
(import java.nio.file.Paths)
(import java.util.stream.Stream)

(def path 
  (Paths/get "." 
    (into-array ["data" "10000000.test.log"])))

(def stream 
  (Files/lines path))

这样我有:

stream
#object[java.util.stream.ReferencePipeline$Head 0x50129b8f
"java.util.stream.ReferencePipeline$Head@50129b8f"]

有没有一种方法可以在不耗尽内存的情况下对其进行迭代？关于 SO 的建议并不是很有帮助。文件约为 1G。

Answer 1

做你会在 java 中做的同样的事情。在其上调用互操作方法，如 (.map stream ...) 或其他任何方法，并在最后将其收集到列表中，或减少它，或任何您需要做的事情。

Clojure 函数不实现流所需的接口(interface)，例如 java.util.function.Function，因此您需要使用 reify 而不是简单的 fn:

(.map stream (reify java.util.function.Function (apply [this x] (foo x))))