core.async のミックスを試しています。ミックス内の入力チャンネルをミュートすることは、バックプレッシャーを実装する可能な方法の 1 つと思われます。以下のコードを使用しています。
(def output-chan (chan))
(def input-chan (chan))
(def mixer (admix (mix output-chan) input-chan))
(toggle mixer {input-chan {:mute true}})
REPL の最後の行を評価すると、
CompilerException java.lang.IllegalArgumentException: No implementation of method: :toggle* of protocol: #'clojure.core.async/Mix found for class: java.lang.Boolean
.
上記のコード例の何が問題になっていますか?
ありがとう!