piatachki
@piatachki

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

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

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

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

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


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

Не работает - коллбек не дергается. Подскажите, пожалуйста, где ошибка?
  • Вопрос задан
  • 32 просмотра
Решения вопроса 1
Xuxicheta
@Xuxicheta Куратор тега Angular
инженер
auditTime, насколько я понял из описания.

никаких схлопываний не надо, takeLast и concatAll работают вообще не так
Ответ написан
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы