我正在使用返回可观察对象的 Angular 2 HTTP 库。 我想对某些错误状态/代码实现重试。
我有一个问题,如果错误不是 429,Observable.of(error)
将在错误情况下执行以重试,但是当所有 2 次重试都失败时,流程的执行将转到success block 而不是 catch block 。
如何让所有重试都失败的流程执行到catch block?
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();
最佳答案
聚会有点晚了,但我最近实现了类似的行为。这是我的解决方案:
post<T>(serviceUrl: string, data: any): Observable<T> {
return Observable.defer(() => {
return super.post<T>(serviceUrl, data);
}).retryWhen((error) => {
return this.refresh(error);
});
}
刷新函数:
refresh(obs: Observable<any>): Observable<any> {
return obs
.switchMap((x: any) => {
if (x.status === 401) {
return Observable.of(x);
}
return Observable.throw(x);
})
.scan((acc, value) => {
return acc + 1;
}, 0)
.takeWhile(acc => acc < 3)
.flatMap(() => {
console.log('Token refresh retry');
return this.tokenRefreshService.refreshToken();
});
}
用例是每当我发出 HTTP 请求并收到 401 响应时,我想刷新 token ,然后使用新 token 重试初始请求。当 401 发生时,我使用 switchMap 返回一个新的 Observable,否则,我返回一个 Observable.throw(x) 来停止执行重试逻辑。
调用代码如下所示(每当您返回 Observable.throw(x) 时调用错误):
this.http.post(x).subscribe(response => {
...
}
}, error => {
...
}
});
关于 Angular 2 RxJS 可观察到的 : RetryWhen filter retry on error Status,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39928183/