This can be done in Clojure with core.async [1] and transducers [2] [1] http://clojure.com/blog/2013/06/28/clojure-core-async-channels.html http://clojure.com/

This can be done in Clojure with core.async [1] and transducers [2] [1] http://clojure.com/blog/2013/06/28/clojure-core-async-channels.html http://clojure.com/blog/2013/06/28/clojure-core-async-channe... [2] https://www.youtube.com/watch?v=6mTbuzafcII https://www.youtube.com/watch?v=6mTbuzafcII