Clojure concurrent pipleline on core.async