Как в Rx.js отловить ошибку в родительском пайпе Subject?

Question

[Pantene742]

https://stackblitz.com/edit/rxjs-jyrfi7?devtoolshe...
В примере выше у меня есть rootSubjec$ = Subject от которого наследуются друге стримы как в примере кода - const firstChildStream$ = rootSubjec$.pipe

В этих стримах в пайпе может быть ошибка и тогда падает весь поток merged$ где

merged$ = merge(rootSubjec$, firstChildStream$, secondChildStream$)

Я могу хендлить ошибку в каждом дочернем потоке(28 закоментированная строка), Но можно как то похендлить ошибку в рутовом стриме в одном месте ? чтоб не повторять код поддерживания ошибки http запроса в каждом дочернем стриме ?

На базе данного кода у меня построен стор типа Ngrx - это вырванная из контекста проблемная часть.
Очень много повторяемого кода будет если я буду хендлить в каждом Екшене Http ошибку, Их 100500.
Хотелось бы как то в рутовом стриме поставить пайп оператор какой то и там хендлить все ошибки которые могут быть
в дочерних стримах

Comments

[Антон Швец]

так как у тебя сделано - никак.
Потому что ошибка должна быть перехвачена еще не выходя из switchMap, иначе вся цепочка отпишется.
Ты уверен что это правильная реализация стора?

[Pantene742]

Антон Швец, Туда попадает Observable от HttpClient. Я просто как в NGRX эффекте обращаюсь к методу в сервисе который возвращает HttpClient.get('qwerty.qwe');
Даже если это плохая реализация мне хотелось бы просто ради интереса перехватить ошибку во всех пайпах акшенов при этом ничего для этого не делать в самих пайпах екшенов