по которой приходит массив объектов, я их начинаю перебирать выполняя сложные операции над ними и плюс вместе с рестом у меня идет подписка на вебсокет через которое начинает приходить сами объекты и этот перебор и выполнение сложных операции начинается заново, теперь собственно вопрос как так их выстроить в поток с фильтрацией убирая дублирующие значения, а также сделать задержку в 1 секунду на одинаковый объект и брать самый последний из того что пришло и только после этого запускать собственно эти сложные функции?
https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/distinctuntilchanged.md или filter
+ один и тот же объект distinctUntilChanged() и debounceTime(1000) можешь поставить
Обсуждают сегодня