4 ms·

I think it could be parallelized by chunking up the input, however the transducer doesn't know how to do that by itself, so the step function would have to be m

I think it could be parallelized by chunking up the input, however the transducer doesn't know how to do that by itself, so the step function would have to be modified somehow.

jjcomer 12y ago
Exactly! core.async had the pipeline mechanism added which allows for the parallel application of a transducer to a channel. https://github.com/clojure/core.async/blob/17112aca9b07ebba6ce760ca01d117c24c80cc9a/src/main/clojure/clojure/core/async.clj#L500 https://github.com/clojure/core.async/blob/17112aca9b07ebba6...