使用core.async通道与转换器时遇ISeq创建错误，求修复方案

问题场景 #

运行《Hands-On Reactive Programming with Clojure》中的core.async示例代码时，抛出IllegalArgumentException: Don't know how to create ISeq from: clojure.core.async.impl.channels.ManyToManyChannel错误，环境为Clojure 1.12.0、clojure.core.async 1.6.681。

原示例代码：

(ns core-async-intro.xforms
  (:require [clojure.core.async :refer [map< filter< chan go <! >! close!]]))

(def result (chan 10))

(def transformed
  (->> result
       (map< inc) ;; creates a new channel
       (filter< even?) ;; creates a new channel
       (into [])))

(defn -main [& args]
  (go
    (prn "result is " (<! transformed)))

  (go
    (doseq [n (range 10)]
      (>! result n))
    (close! result)))

错误原因 #

into []是Clojure标准库中用于将序列转换为向量的函数，但这里它接收的是core.async的ManyToManyChannel对象（map<和filter<返回的都是通道），通道并非可迭代的序列类型，因此触发类型转换错误。

修复方案 #

使用core.async专门为通道设计的into<函数替代标准库的into，该函数会从通道中读取所有数据直到通道关闭，再将数据收集到指定集合中，返回一个包含最终集合的通道。

修改后的代码 #

(ns core-async-intro.xforms
  ;; 新增引入into<
  (:require [clojure.core.async :refer [map< filter< chan go <! >! close! into<]]))

(def result (chan 10))

(def transformed
  (->> result
       (map< inc)
       (filter< even?)
       ;; 用into<替代into
       (into< [])))

(defn -main [& args]
  (go
    (prn "result is " (<! transformed)))

  (go
    (doseq [n (range 10)]
      (>! result n))
    (close! result)))

原理说明 #

into<是core.async针对通道操作的封装，它内部会处理通道的读取逻辑，直到通道关闭后将所有收集到的值存入目标集合（这里是空向量），最终返回的通道会输出这个完整的集合，和原代码的逻辑意图一致，但符合core.async的通道操作规范。

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