Fork me on GitHub

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

    '[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)

    (fn [value] (println "Value in pipeline: " value) value)

  (a/>!! ch1 1)

  ;; prints:
  ;; Value in pipeline:  #<protocols$add_BANG_ [email protected]>
I understand that transducers are not available yet in Clojure 1.6 and that might be the problem. Is there a way to still getting this to work without having to implement pipeline-blocking myself? Thanks.

Alex Miller (Clojure team)11:01:53

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

Alex Miller (Clojure team)11:01:18

There's an example in the async tests


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

Alex Miller (Clojure team)13:01:31

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

Alex Miller (Clojure team)13:01:09

Transducers are just functions