Clojurians Log v2

Hi all, please advice, does it make sense to use reduce with the pipeline-blocking?

(async/pipeline-blocking concurrent
                               output-chan
                               (reduce
                                (fn [acc hour]
                                  (let [acc* (disj acc hour)]
                                    (worker hour context)
                                    (if (seq acc*)
                                      acc*
                                      (reduced :done))))
                                hours)
                               (async/to-chan hours))

thanks

i haven't tried that before. async/pipeline-blocking requires a transducer.

i've used pipeline-blocking before, but with a transducer.

that is my concern, that reduce may not work 😞

thanks

I think pipeline-blocking returns channel which is close when processing is done.