如何处理可观察的错误但继续关注可观察的？答案

【问题标题】：how to handle observable errors but continue with follow on observables?如何处理可观察的错误但继续关注可观察的？
【发布时间】：2017-04-18 02:40:16
【问题描述】：

我有一个 observable，在处理其他 observable 的过程中是否有一个 http。对于除 200 之外的任何 http get 响应代码，我想记下此错误，但继续进行下一个 observable。

到目前为止，我有这个：

this.getConfigurationSettings()
    .do(config => {
        console.log('configuration settings.: ', config);
        this.configSettings = config;
        this.subscriptionService.setWSAddressProvider('badUrl');
    })
    .switchMap(config => this.askForWSData())
    .do(config =>
        console.log('askForWSData' + config))
    .switchMap(r => this.processWSData())
    .subscribe(
        config => {
            console.log('start of data processing: ' + config);
        },
        err => {
            // Log errors if any
            console.log(err);
        },
        () => console.log('app exiting'));

并且可以返回http错误码的observable如下：

setWSAddressProvider() : Observable<string[]> {
    return this.http.get('badUrl')
        .map((res:Response) => {
            this.address = res.text();
            return [res.text()];
        });
        // .catch((error:any) =>
        // Observable.throw('Server error')
        // );
}

上述情况生成一个 400 响应代码。我想记录该回报，但继续其他可观察的。该怎么做？

【问题讨论】：

标签： angular system.reactive

【解决方案1】：

可以使用catch处理http errors

setWSAddressProvider() : Observable<string[]> {
    return this.http.get('badUrl')
        .map((res:Response) => {
            this.address = res.text();
            return [res.text()];
        });
       .catch((error: Response | any) => {
           if (error instanceof Response) {
                if (error.status === 400) {
                    console.log("Server responded with 400");
                    // Create a new observable with the data for the rest of the chain
                    return Observable.of([]);
                }
           }
           // Re-throw unhandled error
           return Observable.throw(err);
    });

}

【讨论】：

【解决方案2】：

尝试使用 Observable onErrorResumeNext 函数：

setWSAddressProvider() : Observable<string[]> {
    return this.http.get('badUrl')        
        .map((res:Response) => {
            this.address = res.text();
            return [res.text()];
        })
       .onErrorResumeNext((error: Response | any) => {
           if (error instanceof Response) {
                if (error.status === 400) {
                    console.log("Server responded with 400");
                }
                return [];
           }
    });
  }

见https://xgrommx.github.io/rx-book/content/getting_started_with_rxjs/creating_and_querying_observable_sequences/error_handling.html#ignoring-errors-with-onerrorresumenext

这个答案： Difference between catch and onErrorResumeNext

【讨论】：