Angular 2 RxJS Observable:重试当错误状态时过滤器重试
发布时间:2020-12-17 07:56:30 所属栏目:安全 来源:网络整理
导读:我正在使用Angular 2 HTTP库,它返回一个observable. 我想在某些错误状态/代码上实现重试. 我有一个问题,如果错误不是429,Observable.of(错误)将在错误情况下执行以重试,但是当所有2次重试失败时,流程的执行将转到成功块而不是catch块. 如何在所有重试中执行
我正在使用Angular 2 HTTP库,它返回一个observable.
我想在某些错误状态/代码上实现重试. 我有一个问题,如果错误不是429,Observable.of(错误)将在错误情况下执行以重试,但是当所有2次重试失败时,流程的执行将转到成功块而不是catch块. 如何在所有重试中执行流程以捕获块失败? 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响应时,我想进行令牌刷新,然后使用新令牌重试初始请求.当401出现时,我使用switchMap返回一个新的Observable,否则,我返回一个Observable.throw(x)来阻止重试逻辑被执行. 调用代码看起来像这样(每当你返回一个Observable.throw(x)时都会调用错误): this.http.post(x).subscribe(response => { ... } },error => { ... } }); (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
相关内容
- Linux真的很流行吗?现实却与我们认知中的相反……
- Scala json4s密封了特征作为枚举
- Bootstrap 实例 - 标签页(Tab)插件
- scala – 混合Akka 2,Play2-mini框架和HTTP
- 编辑器 – 如何在vim中为指定的文本着色?
- unix – 如何读取.man文件不在manpath?
- 解决cxf+bboss发布的webservice缺少<wsdl:types>和<
- 是否可以在Scala中实现不使用反射的`??`(来自C#的空合并运算
- 基于xfire实现webservice的实例 .
- 使用AngularJS的Spring Boot和CSRF – Forbitten 403 – >错