c# – IObserver – 调用IObserver.OnError时观察者应该做什么
发布时间：2020-12-15 05:37:38 所属栏目：百科 来源：网络整理
导读：我在我的项目中使用IObserver / IObservable接口. CommandReader是一个IObservable,它不断从流中读取数据,然后将其传递给CommandHandler IObserver. 当底层流关闭(例如连接死亡)时,我将通过IObserver.OnError(exception)方法通知观察者 观察者收到此通知时应
|
我在我的项目中使用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可能会更好. （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |