clojure - 使用 core.async pub/sub 时如何避免丢失项目？

Question

我有一个充当发布商的 channel :

(def publisher (async/chan))
(def publication (async/pub publisher :topic))

由于 sub/pub 的性质，当我这样做时:

(async/put! publisher {:topic :foo})

消息被发布所使用，并且由于没有订阅者，因此它将被删除。

如果我尝试订阅 :foo 主题:

(def reader (async/chan))
(async/sub publication :foo reader)
(async/go (println "got val " (async/<! reader)))

我不会看到任何打印内容。但如果我在发布者中放入更多项目:

(async/put! c1 {:topic :foo :msg "after"})
==> got val {:topic :foo :msg "after"}

有没有办法不丢失(例如，发布者生成的最后 n 项即使订阅者尚未订阅？

)

Answer 1

pub接受给定主题的 buf-fn 函数。该函数应该返回一个缓冲区。例如dropping-buffer或sliding-buffer。因此，如果您希望缓冲 :foo 主题:

(pub pub-ch :topic #(if (= % :foo) (sliding-buffer 10) nil))

另请参阅relevant code section .