Как собирать данные с основной части каналов core.async?

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.