Angular 2 RxJS 可观察到的 : Retry except on 429 status

Question

我已经编写了我的 Observable(来自 HTTP 请求)以在失败时重试。但是，如果服务器响应 429 太多请求 错误，我不想重试。

无论如何，当前的实现都会重试两次，间隔 1 秒。

return this.http.get(url,options)
    .retryWhen(errors => {
        return errors.delay(1000).take(2);
    })
    .catch((res)=>this.handleError(res));

errors 是一个 Observable。如何获取导致错误的底层 Response 对象？有了它，我可以访问服务器的状态代码，并且只有在它不是 429 时才重试:

return this.http.get(url,options)
    .retryWhen(errors => {
        if($code == 429) throw errors;
        else return errors.delay(1000).take(2);
    })
.catch((res)=>this.handleError(res));

如何在 retryWhen 中获取状态码？

Live demo on Plunker

Angular 2 rc.6、RxJS 5 Beta 11、Typescript 2.0.2

Answer 1

您可以将 429 错误的处理组合到传递给 retryWhen 的 errors 可观察对象中。从 errors observable 发出的错误如果是从服务器接收到的错误，将包含一个 status 属性。

如果您不想在出现 429 错误时重试，而是希望抛出错误，您可以这样做:

return this.http.get(url,options)
    .retryWhen((errors) => {
        return errors
            .mergeMap((error) => (error.status === 429) ? Observable.throw(error) : Observable.of(error))
            .delay(1000)
            .take(2);
    })
    .catch((res) => this.handleError(res));

相反，如果您希望 HTTP 可观察对象在不发出错误或响应的情况下完成，您可以简单地过滤 429 错误。