RxJS：以每x秒

Question

与RXJs我想实现这样的事情：

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

1个呼叫f每500ms，无论是否有一个clickEvent或不。 仅当clickStream确实发送了clickEvent，然后至少停止了500ms时，第2版才会调用f。

只要clickStream正在发射事件，我想每500ms呼叫f。只要它停止发射，f应该是最后一次。如果clickStream重新启动发出相同的情况应该再次发生。

Answer 1

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