通过 RXJ，我试图实现这样的目标:
clickStream.bufferWithTime(500).subscribe(f)clickStream.throttle(500).subscribe(f)
版本 1 每 500 毫秒调用一次 f，无论是否有 clickEvent。
仅当 clickStream 确实发送了 clickEvent 然后停止至少 500 毫秒时，版本 2 才会调用 f。
只要 clickStream 正在发出事件，我想每 500 毫秒调用一次 f 。一旦它停止发出，f 就应该最后一次调用。如果 clickStream 重新启动以发出相同的情况，应该会再次发生。
最佳答案
clickStream.bufferWithTime(500).filter(arr => arr.length > 0).subscribe(f)
关于javascript - RxJS:每隔x秒进行一次，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31192005/