我有一个热门的IObservable<T>,可能会引发异常。但是,我想继续。我想我可以使用Retry运算符。但是,如果我还可以通过单独的IObservable<T>收听IObservable<Exception>中的任何错误,那就太好了。有可能吗?
IObservable<T>
Retry
IObservable<Exception>
我有一个热的IObservable 可能会引发异常。但是,我想继续。我想我可以使用Retry运算符。但是,如果我还可以听的话,那将是非常不错的...
您的案例大大简化了,因为您有一个可观察的热点。
OnError是您价值流之外的通知,因此我们可以实现
OnError
您的问题的前提违反了the observable contract: