example pipeline-async

pipe-async.clj

(require '[clojure.core.async :as a])

(def from (a/chan 10))
(def to (a/chan 10))

(a/onto-chan!! from [1 2 3 4 5])

(a/<!! from)

(a/pipeline-async 4
                  to
                  (fn [i rc]
                    (a/>!! rc (str "foo-" i))
                    (a/close! rc))
                  from)

(a/<!! to)