Хорошо, forkJoin
, вероятно, то, что вы ищете, но если вы хотите обрабатывать обе ошибки, вам нужно будет связать каждый источник с catchError
и возвращать ошибки как next
уведомления.
В противном случае один сбойный Observable обнаружил бы цепочку, и вы никогда не узнаете, вышел ли из строя второй Observable или какой из двух Observable вышел из строя.
forkJoin([
source1$.pipe(catchError(error => of(error))),
source2$.pipe(catchError(error => of(error))),
]).subscribe(([reponse1, response2]) => {
if (reponse1 instanceof ErrorResponse || reponse2 instanceof ErrorResponse) {
// or whatever works for you
}
});