如何处理可观察的错误，但继续跟踪可观察的？

Question

我有一个可观察的事情，http处理其他可观察事件的过程中。 在http获取除200之外的任何其他响应代码的情况下，我想记下此错误，但继续进行下一个可观察事件。

到目前为止，我有这样的：

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错误代码可观察如下：

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响应代码。我想记录那个回报，但继续到其他观察。 如何做到这一点？

Answer 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); 
    }); 

}

Answer 2

尝试使用可观察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