Angular 2 RxJS Observable：重试当错误状态时过滤器重试

我正在使用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 => {
        ...
        }
    });

Angular 2 RxJS Observable：重试当错误状态时过滤器重试

相关文章