Fork me on GitHub
#core-async
<
2019-03-30
>
idiomancy20:03:35

fwiw, I think I now have the best version of that

idiomancy20:03:54

(def mchain! (comp chain! (ingo a/merge) (p a/into [])))

idiomancy20:03:01

since merge gives you results in the order they become ready, if you just compose a merge with the chain! operation, then you have a performant way to flatten out channels

idiomancy20:03:08

ingo is just -> (defn ingo [f] (fn [c] (go (f (<! c)))))