Angular 2 RxJS Observable: RetryWhen фильтр повторяется при ошибке Status
Я использую Angular 2 HTTP-библиотеку, которая возвращает наблюдаемую. Я хочу реализовать повторную попытку при определенном статусе ошибки / коде.
У меня есть проблема, если ошибка не 429,Observable.of(error)
выполняется в случае ошибки, чтобы повторить попытку, но когда все ваши 2 попытки повторяются, выполнение потока переходит к блоку успеха вместо блока перехвата.
Как сделать, чтобы выполнение потока для перехвата блока при всех неудачных попытках повторялось?
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));
это решит мою проблему
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();