在一端，我有一个可能偶尔抛出错误的流:
this.behaviorSubject.error(error)
不过，稍后我想继续这条流:
this.behaviorSubject.next(anotherValue)
另一方面，我有一个订阅者订阅了behaviorSubject.asObservable().
在subscribtion中，我正在处理值和错误:
.subscribe(
( value ) => { /* ok */ },
( error ) => { /* some error */ }
);
我希望其效果与简单的onSuccess和onError回调相同，每次发生错误时都会调用onError，并且不会阻止以后进行onSuccess次调用.如何使用RXJS实现这一点？
我已经研究了catch，但它似乎只是防止订阅者调用错误.
这是不可能的.
How to work with this: RxJS的基本概念是，任何error或complete次调用基本上都会产生一个流.这一概念迫使您不仅要正确处理错误，还要正确处理应用程序中的数据流.例如，BehaviorSubject通常用于保存数据，但是它也应该用于包括检索/创建该数据的过程，并处理在检索数据期间可能发生的错误.
所以如果你想要go by the book，你应该split up your flow into two parts:
例如，您的数据流可以如下所示(如草图所示):
store.ts
dataStore: BehaviorSubject<IData> = new BehaviorSubject<IData>();
errorMessage: BehaviorSubject<IErrorMsg> = new BehaviorSubject<IErrorMsg>();
data-retrieval.ts
fetchDataById(id: string) {
httpService.get(`some/rest/endpoint/${id}`)
.subscribe(handleData, handleError);
}
handleData(data: IData) {
errorMessage.next(null);
dataStore.next(data);
}
handleError(error: Error) {
errorMessage.next(error.message);
dataStore.next(null);
}
"But this looks like a lot of overhead..."-是的，但是它确保了应用程序中干净、易于理解的数据流，易于测试和维护.此外，还可以使用现成的store 概念，如ngrx或redux.