RXJS - Fehler in der Kette von Observablen Umgang

Question

Ich habe gerade gelernt, nicht zu nisten abonniert, so stattdessen verwende ich switchMapTo als Mittel jeder aufeinanderfolgenden Stufe auf die Vollendung des vorherigen Schritt beginnen:

z.B.

const s1$ = this.retrieveAnnualLeaveVariables();  
    const s2$ = s1$.switchMapTo(this.initialise());  
    const s3$ = s2$.switchMapTo(this.retrieveData()); 
    const s4$ = s3$.switchMapTo(this.accumulateAnnualLeaveRecords()); 
    s4$.subscribe(() => outerStream.next(someResults)) // pass the results to the outerStream 

Was ich jetzt unklar bin, ist, wie Fehler zu integrieren in prägnanter Weise der Handhabung, so dass ich ein Fehlersignal zu outerStream im Fall eines Problems senden kann, begegnete eine beliebige Stelle innerhalb der Kette.

Ich habe versucht, die folgenden mit dem ersten

.catch(e => { 
     return Observable.of<any>([]); 
    }); 

Befestigung jedoch:

• sollte ich anfügen, dies zu jeder switchMapTo? oder kann ich es an einem Ort verwalten?

• Welchen Zweck gibt zurück Observable.of ([]); serve - rufe ich die Fehler-Methode auf meinem outerStream von hier?

• Ich habe nicht herausgefunden, wie man die Kette von Ereignissen stoppt, sobald man einen Fehler wirft - wie mache ich das?

Vielen Dank für Ihre Hilfe!

Answer 1

Zuerst sollten Sie die Operatoren auf Ihre Observable verketten, anstatt jedes Mal eine neue Konstante zu erstellen, wenn Sie switchMapTo aufrufen. Dann bekommst du das.

this.retrieveAnnualLeaveVariables() 
    .switchMapTo(this.initialise()) 
    .switchMapTo(this.retrieveData()) 
    .switchMapTo(this.accumulateAnnualLeaveRecords()) 
    .subscribe(() => outerStream.next(someResults)) 

Dann, wenn Sie diese haben, können Sie die catch vor der Zeichnung hinzufügen. In der catch können Sie entweder einen neuen "Fallback" -Wert als beobachtbar, einen leeren Observable zurückgeben oder einen anderen Fehler werfen.

Wenn Sie die Kette anhalten möchten, sollten Sie eine leere Observable über Observable.empty() zurückgeben. Wenn Sie dies zurückgeben, wird das Observable abgeschlossen, ohne die angegebene Subskriptionsfunktion aufzurufen.

Ergebnis:

this.retrieveAnnualLeaveVariables() 
    .switchMapTo(this.initialise()) 
    .switchMapTo(this.retrieveData()) 
    .switchMapTo(this.accumulateAnnualLeaveRecords()) 
    .catch(() => Observable.empty()) 
    .subscribe(() => outerStream.next(someResults))