如何使用滴落缓冲区制作流形流？

Question

使用 core.async 我可以轻松创建带删除缓冲区的频道：

(async/chan (async/dropping-buffer 10))

是否可以使用删除缓冲区创建 manifold 流？

Answer 1

您可以通过创建 (s/stream 10) 并使用 (try-put! msg 0) 而不是 put! 来获得相同的结果，这样对完整流的任何放置都会立即超时。