system.reactive - IObservable.Catch 可以继续使用相同的可观察对象吗

Question

假设有一个IObservable:

IObservable<long> obs = ...;

我可以做以下事情来保证 Observable 永远不会停止吗？

IObservable<long> resilientObs = obs.Catch(obs);

因此，当捕获到异常时，继续执行生成异常的相同序列。

Answer 1

您只能使用 Cold 可观察对象(即每次返回新序列的可观察对象)执行此操作

obs.Retry();

但即便如此，你也不是在“恢复”一个 Observable，你只是重新启动它。

如果你想保持持久连接(比如，一个因错误而终止的网络套接字)，你需要一个工厂函数 + Defer:

Observable.Defer(() => createNewObservable())
    .Retry();

为了给您更好的建议，您需要告诉我们什么是 obs 的性质以及您想要做什么。