使用reduced的转换器通道工作不正常

Question

`
(def ch (chan 1 (take 2)))

(put! ch 1)
(put! ch 2)
(put! ch 3)

(take! ch identity)

`

ClassCastException clojure.lang.PersistentVector cannot be cast to java.util.concurrent.locks.Lock clojure.core.async.impl.channels.ManyToManyChannel (channels.clj:55)

如果在此之前进行一次take，以确保缓冲区大小合适，则不会发生这种情况。但问题似乎并不仅与缓冲区大小有关。

`
(def ch (chan 1 (take-while true?)))

(put! ch true)
(put! ch false)
(put! ch false)

(take! ch identity)
`

ClassCastException clojure.lang.PersistentVector cannot be cast to java.util.concurrent.locks.Lock clojure.core.async.impl.channels.ManyToManyChannel (channels.clj:55)

Answer 1

参考：https://clojure.atlassian.net/browse/ASYNC-129（由lgs32a报告）