如何使用下降缓冲区制作歧管流？

Question

使用core.async 我可以轻松地创建一个带有丢弃缓冲区的通道：

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

是否可以使用丢弃缓冲区创建manifold 流？

Answer 1

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