Angular 2 RxJS Observable：RetryWhen 过滤器在错误状态下重试

Question

我正在使用Angular 2的HTTP库，它返回一个Observable。我想在特定的错误状态/代码上实现重试。

但是，如果错误不是429，则在错误情况下执行Observable.of(error)以进行重试，但当您的2次重试全部失败时，流程执行到成功块而不是catch块。

如何使流程在所有重试失败时执行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();

- sulabh rastogi

---

https://dev59.com/xprga4cB1Zd3GeqPrLt1#39928110 - sulabh rastogi

Answer 1

虽然晚了一点，但我最近实现了类似的行为。这是我的解决方案:

  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.throw(x)，以停止执行重试逻辑。

调用代码如下（其中error是每当您返回Observable.throw(x)时调用的函数）：

 this.http.post(x).subscribe(response => {
      ...
        }
    }, error => {
        ...
        }
    });

- Radu Cojocari

---

我试了你的代码，它运行得很好。非常感谢你。 - Eric Wei