如何从大量 core.async go 通道中收集数据？

Question

如何从大量go 频道收集数据？下面的代码我得到assert failed: <! used not in (go ...)。我知道我为什么得到它，我在问从所有渠道消费的最佳方式是什么。

(->> state :pods (map #(go [(pd/id %) 
    (<! (f/pod-metrics fleet %))])) (map <!) (into {}))

Answer 1

使用https://clojuredocs.org/clojure.core.async/merge 将您的源通道合并为一个，然后使用<!! 从中获取val。请注意，<! 只能在 go 块内使用。