Hi, I have an issue getting clojure.core.async/pipeline-blocking to work on Clojure 1.6:

(require
    '[clojure.core.async :as a])
  (def ch1 (a/chan))
  (def ch2 (a/chan))

  (a/go-loop []
    (when-some [msg (a/<! ch2)]
      (println "Arrived on ch2: " msg)
      (recur)))

  (a/pipeline-blocking
    1
    ch2
    (fn [value] (println "Value in pipeline: " value) value)
    ch1)

  (a/>!! ch1 1)

  ;; prints:
  ;; Value in pipeline:  #<protocols$add_BANG_ clojure.core.async.impl.protocols$add_BANG_@7c9ec413>

Transducers are just functions so they do "work" in 1.6, you just have to define them yourself

There's an example in the async tests

https://github.com/clojure/core.async/blob/master/src/test/clojure/clojure/core/pipeline_test.clj#L7

@alexmiller: now it works, thank you! so mapping imitates native transducer functionality?

It's the exact same thing - that's basically copy/paste

Transducers are just functions