我在我的项目中使用IObserver / IObservable接口.
CommandReader是一个IObservable,它不断从流中读取数据,然后将其传递给CommandHandler IObserver.
当底层流关闭(例如连接死亡)时,我将通过IObserver.OnError(exception)方法通知观察者
观察者收到此通知时应该怎么做？它应该从观察中释放出来吗？或者是父母班的责任？
解决方法
对于初学者,通常不应该实现自己的IObservable和IObserver对象.你的问题有点暗示为什么.要使基本行为正确是非常困难的.
现在每次调用IObservable.Subscribe都会返回一个Idisposable.如果Subscribe的调用者希望在调用OnCompleted或OnError之前取消订阅observable,则使用此方法.但是,如果调用OnCompleted或OnError,则会自动丢弃Idisposable.因此,当可观察的集合完成时,Rx会自动清理.
每个观察者都不需要管理自己的订阅生命周期.观察者只需要响应OnCompleted / OnError消息.
在您的代码中,我建议您考虑稍微更改您的代码.我希望带有Subscribe方法的CommandReaderPublisher类可能比CommandReader类更合适. Rx流完成后,无法继续使用.
另外我想知道当底层流关闭时,调用OnCompleted会比OnError(异常)更好.如果发生错误则没关系,但如果关闭则ONCompleted可能会更好.
