如何将Clojure数据以EDN格式写入Node.js输出流？

你当前的方案会生成完整的EDN字符串再转成Readable流，对于超大型映射来说，会占用大量内存，且多了不必要的中间层。可以通过实现CLJS的Writeable协议，让clojure.edn/write直接将序列化内容逐段写入Node.js的输出流，无需创建完整字符串和额外的Readable流。

实现代码 #

(ns user
  (:require ["stream" :as stream]
            [clojure.edn :as edn]
            [cljs.core :as core]))

; 实现适配Node.js可写流的Writeable实例
(defn node-stream-writer [output-stream]
  (reify
    core/Writeable
    (-write [_ s]
      ; 将序列化后的片段写入输出流
      (.write output-stream s)
      nil)
    (-flush [_]
      ; 刷新流缓冲区
      (.flush output-stream))
    (-close [_]
      ; 结束输出流
      (.end output-stream))))

(let [data {:very "large" ; 你的超大型映射
            ; ... 更多键值对
            }
      output-stream (-> ^js file .createWriteStream)]
  ; 直接将data序列化到输出流
  (edn/write (node-stream-writer output-stream) data)
  
  ; 监听流完成事件，处理后续逻辑
  (.on output-stream "finish" (fn []
                                (resolve output-stream))))

方案优势 #

1. 内存效率更高：无需生成完整的EDN字符串，序列化过程中逐段写入流，避免大对象占用过多内存，尤其适合超大型映射场景。
2. 减少中间环节：直接对接输出流，省去了Readable流的创建和管道步骤，流程更简洁，性能损耗更低。
3. 原生EDN序列化支持：复用clojure.edn/write的标准序列化逻辑，保证EDN格式的正确性，无需手动处理序列化细节。

补充说明 #

如果需要异步控制流的结束，监听输出流的finish事件即可，该事件会在所有数据写入完成且流关闭时触发，替代原方案中Readable的end事件监听逻辑。

内容的提问来源于stack exchange，提问作者Witek