Clojure concurrent pipleline on core.async - View it on GitHub