An example of pipelining in Clojure using core.async