RxJS:每x秒取一次

Question

使用RXJ，我试图实现这样的目标：

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

版本1每500 or调用一次f，不管是否存在clickEvent。只有当f发送了一个clickEvent，然后停止了至少500 at时，版本2才会调用clickEvent。

只要f发出事件，我想每500毫秒打一次电话给clickStream。一旦停止发出，f应该是最后一次调用。如果clickStream重新启动，那么同样的情况就会再次发生。

Answer 1

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