Как упростить код?

Question

[G F]

observable$.subscribe(result => {
  of(result).pipe(
    mergeMap(x => {...}),
    catchError(err => throwError(err))
  ).subscribe(...)
}

В observable$ прилетают новые ивенты по клику, которые генерируют объект result. Внутри mergeMap логика запросов на сервер с данными из result. У каждого такого запроса нужно хендлить ошибки.
Как можно избавиться от вложенных сабскрайбов?

Comments

[Роман]

Reactive Extensions это же древность древняя, я уже забыть успел как с этим работать)
Поддерживаете какой то винтажный проект?

[G F]

Роман, да нет, это rxjs, просто тега под него не нашлось)

Answer 1

[kolebayevv]

используйте switchMap

observable$.pipe(
    switchMap((result) => {
        return of(result).pipe(.....)
     })
).subscribe(...)

Comments

[G F]

Там проблема в том что выброс ошибки обрывает стрим. вообще не актуально уже, тот код надо полностью рефакторить чтобы таких кейсов не возникало. Спасибо за помощь.