rx js наблюдаемый поток: как выполнить побочный эффект для каждого n-го события?

Question

Я хочу выполнить побочный эффект после каждых 20 излучений в интервальном потоке, который продолжается бесконечно. Можно ли выполнить побочный эффект do / take после того, как n испускает повторяющийся цикл с наблюдаемым потоком rx js?

Спасибо

Answer 1

Вы можете использовать windowCount

Просто так:

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