зачем двойной обход массива?

Добрый день! У меня есть метод в сервисе в котором я подписываюсь на observable, вызываю метод в компоненте и там отписываюсь от подписки (использую takeUntil) . Правильно ли так делать, если нет то какие есть предложения.

notifier это сабджект?

да

ну вполне правильно)

в компоненте

но можно декоратор поискать, который это будет делать автоматом

да вот я тоже нашел
https://github.com/NetanelBasal/ngx-auto-unsubscribe

спасибо за ответ

мб кто знает как применить combineLatest ? У меня есть сервис, что берет данные с АПИ и при нажатии на кнопку load more данные догружаются еще и вызывается функция loadMore. В ней у меня есть nextPostsPage$ которая получает дополнительные данные. И combineLatest , который принимает в себя this.post$ - уже подгруженные посты и nextPostsPage$ - только что полученные новые. Подсказали что так можно сделать, но тут застрял и не знаю как применить, может кто сможет подсказать

Да просто после каждой подгрузки добавляй результаты в какой то behavior subject и подпиши на него интерфейс

подписываешься на это дело и принимаешь данные вот и все

он отличается только тем что принимает в себя несколько observable

Уже в ЛС ответил

спасибо буду ппробовать)

Подскажите, почему  ангуляру просто посрать на то что я ему  спецом ошибку даю, и он ее отказывается обрабатывать?

Где скармливаю ошибку:
foo = () => new Observable(obs => obs.error(new Error('error')))

Где он должен ее обработать:

this.foo().subscribe(() => SOMEFUNCTOBENOTCALLED, SOMEFUNCTOBECALLED)

Проблема в том, что в subscribe, даже когда в обсервере прилетает ошибка, все равно вызывает первую функцию, а не ту, что должна на ошибку реагировать

catchError