rxjs可观察的流：如何在每个第n个事件上执行副作用？

Question

我想在无限期连续的间隔流上每发射20次后执行副作用。在n上以rxjs可观察流重复循环发射后，是否可以执行do / take副作用？

谢谢

Answer 1

您可以使用windowCount

就这样简单：

Observable
    .of(...)
    .windowCount(20)
    .switchMap(val => val.takeLast(1))
    .subscribe(val => console.log(val));