Как схлопнуть собтия в стриме RXJS по времени?

Question

[piatachki]

Подскажите, пожалуйста, новичку.

Есть стрим, которые генерирует события крайне неравномерно - может минуту молчать, а потом 100 событий в секунду. Хочу разбить события на интервалы по времени и пропускать только последнее событие в интервале (если они в интервале вообще были).

Судя по документации, windowsTime(500) должно бить стрим на подстримы по 0.5 секунды. Соорудил конструкцию:

.pipe(
        windowTime(500),
        takeLast(1),
        concatAll()
      ).subscribe(...)

в расчете на то, что windowTime будет бить стрим на интервалы, takeLast будет брать последнее значение с каждого интервала, а concatAll объединит их все снова.

Не работает - коллбек не дергается. Подскажите, пожалуйста, где ошибка?

Answer 1

[Антон Швец]

auditTime, насколько я понял из описания.

никаких схлопываний не надо, takeLast и concatAll работают вообще не так

Comments

[piatachki]

Да, точно. То, что я добивался. Спасибо!