javascript - RxJS:每隔x秒

使用RXJ，我正在尝试实现以下目标：


clickStream.bufferWithTime(500).subscribe(f)
clickStream.throttle(500).subscribe(f)


无论是否有clickEvent，版本1每500ms调用一次f。
仅当clickStream确实发送了clickEvent然后停止了至少500ms时，版本2才调用f。

只要f发出事件，我想每500ms调用一次clickStream。一旦它停止发射，f应该最后一次被调用。如果clickStream重新启动以发出相同的光，则应再次发生。

最佳答案

clickStream.bufferWithTime(500).filter(arr => arr.length > 0).subscribe(f)

关于javascript - RxJS:每隔x秒，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/31192005/