Is there a way to combine multiple core.async channels, but take all from the first until it is closed, then all from the second, e.t.c.?

Essentially a concat but on channels instead of a lazy seq

I have

(vec (concat
       (<! (async/into [] schedule-ch))
       (<! (async/into [] cp-ch))
       (<! (async/into [] c-ch))))

well, that could be simplified with a plain old reduce over a vector of channels

(reduce #(into % (<! (async/into [] %2)) [] [schedule-ch cp-ch c-ch])

the reduce won't work because core.async/go doesn't rewrite over function boundaries

(the function being anonymous there)