c# - IObserver -- 当 IObserver.OnError 被调用时，观察者应该做什么

Question

我在我的一个项目中使用了 IObserver/IObservable 接口(interface)。

CommandReader 是一个 IObservable，它不断从流中读取数据，然后将其传递给它的 CommandHandler IObserver(s).

当底层流关闭时(例如连接终止)，我将使用 IObserver.OnError(exception) 方法通知观察者

观察者收到这个通知应该怎么办？它应该从 observable 中释放自己吗？或者这是父类的责任？

Answer 1

对于初学者，您通常不应该实现自己的IObservable 和IObserver 对象。你的问题有点暗示为什么。很难使底层行为正确。

现在每次调用 IObservable.Subscribe 都会返回一个 IDisposable。如果 Subscribe 的调用者希望在调用 OnCompleted 或 OnError 之前取消订阅可观察对象，则使用此方法。但是，如果 OnCompleted 或 OnError 被调用，则 IDisposable 会被自动释放。因此，当一个可观察集合完成时，Rx 会自动自动清理。

每个单独的观察者不需要管理自己的订阅生命周期。观察者只需要响应OnCompleted/OnError消息即可。

在您的代码中，我建议您考虑稍微更改您的代码。我希望具有 Subscribe 方法的 CommandReaderPublisher 类可能比 CommandReader 类更合适。一旦 Rx 流完成，它就不能继续使用。

我还想知道在底层流关闭时调用 OnCompleted 是否会比 OnError(exception) 更好。如果发生错误，那很好，但如果它关闭，则 ONCompleted 可能会更好。