| (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