Angular 2 RxJS Observable: RetryWhen Filterwiederholung bei Fehler Status
Ich verwende die Angular 2-HTTP-Bibliothek, die eine Observable zurückgibt. Ich möchte einen erneuten Versuch für einen bestimmten Fehlerstatus / -code implementieren.
Ich habe ein Problem, wenn der Fehler nicht 429 ist,Observable.of(error)
wird im Fehlerfall ausgeführt, um es erneut zu versuchen, aber wenn alle 2 Versuche fehlschlagen, wird die Ausführung des Ablaufs zum Erfolgsblock anstatt zum Fangblock weitergeleitet.
Wie kann die Ausführung des Flows zum Abfangen des Blocks bei allen Wiederholungsversuchen fehlschlagen?
return this.http.get(url,options)
.retryWhen((errors) => {
return errors
.mergeMap((error) => (error.status === 429) ? Observable.throw(error) : Observable.of(error))
.take(2);
})
.toPromise()
.then((res:Response) => console.log('In Success Block'))
.catch((res) => this.handleError(res));
wird es mein Problem lösen
return this.http
.post(url, JSON.stringify(body), requestOptions).retryWhen((errors) => {
return errors
.mergeMap((error) => (error.status === 404) ? Observable.throw(error) : Observable.of(error))
.take(2);
}).map((res:Response) =>{
if (res.status === 200)
return res;
else
return Observable.throw(res);
})
.toPromise();