(defn process! [path fname npar] | |
(let [lines (mult (stream-lines-from path)) | |
aggregate-tap (tap lines (chan 1024)) | |
count-tap (tap lines (chan 1024))] | |
(<!! (async/reduce | |
(fn [_ v] (println v)) | |
"" | |
(async/merge [(aggregate-field fname aggregate-tap npar) | |
(count-lines count-tap npar)]))))) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment