Pipeline based on clojure core.async

By dennis_zhuang