javascript - 不带缓冲的节流流

Question

我有一些想要限制的 Toast 消息。我尝试使用缓冲区，但后来我在数组中收到了一堆消息，而我真正希望的是这些消息只是保留在流中，直到我请求它们。我最终做的是用间隔流压缩我的消息流

var messageStream = Rx.Observable.FromEvent(..., 'click');
var intervalStream = Rx.Observable.interval(5000);
messageStream.Zip(intervalStream, (x,_)=>x).subscribe(showToast(x));

有没有更优雅的方法来做到这一点？

Answer 1

看看controlled 。它使您能够对值进行排队，等待您 .request(x) x 值。请谨慎使用，因为这意味着内存将用于缓冲值，并且内存不是无限的。这也可能是一本不错的读物:backpressure