(defn count-lines [channel npar] | |
(let [counters (for [_ (range npar)] | |
(w-counter channel))] | |
(async/reduce + 0 (async/merge counters)))) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment