Instead, I found a way to use (m/eductions (mapcat identity)) to granularize the flows

Can you reduce and join one at a time?

There's also cat in clojure.core

I was also wondering the same a few times, could be great to collect some code snippets in the wiki: https://github.com/leonoel/missionary/wiki