加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 百科 > 正文

c# – 如何处理IObservers?

发布时间:2020-12-15 18:35:55 所属栏目:百科 来源:网络整理
导读:我正在使用Reactive Extensions在我的ViewModel(Silverlight和/或Wp7应用程序)中轻松处理事件.为了简单起见,我想在我的VM的ctor中有这样的一行: Observable.FromEventPropertyChangedEventArgs( h = MyObject.PropertyChanged += h,h = MyObject.PropertyCh
我正在使用Reactive Extensions在我的ViewModel(Silverlight和/或Wp7应用程序)中轻松处理事件.为了简单起见,我想在我的VM的ctor中有这样的一行:
Observable.FromEvent<PropertyChangedEventArgs>(
                            h => MyObject.PropertyChanged += h,h => MyObject.PropertyChanged -= h)
    .Where(e=>e.PropertyName == "Title")
    .Throttle(TimeSpan.FromSeconds(0.5))
    .Subscribe(e=>{/*do something*/});

这将返回一个IDisposable对象,如果处置将取消订阅. (我在这个假设中是对的吗?)
如果我没有提及它,迟早会收集它,我的处理程序将被取消订阅.

我通常有一个List< IDisposable>在我的虚拟机中,我添加订阅,但我觉得它很脏,好像我没有以正确的Rx方式做某事.

在这种情况下,最佳做法,推荐模式是什么?

解决方法

您的第一个假设是正确的,IDisposable用于取消订阅.但是,您无需保留对IDisposable的引用,以防止收集观察者. IObservable将需要保持对观察者的引用以便能够调用其方法,从而只要观察者活着就保持观察者活着.

精明的读者会意识到我有点乞求这个问题,因为我认为不会收集观察者.为了解决这个问题,让我们对幕后发生的事情做出一些合理的猜测.第一个观察者正在订阅一个事件.这意味着从我们订阅我们取消订阅的时间开始,具有该事件的对象具有对我们的观察者的引用.由于Rx运算符必须在某一点订阅它们的源,因此可以假设事件观察者具有对Where观察者的引用,其中引用了Throttle观察者,当然这是指我们的最终观察者.

由于我们无法取消订阅,因此将观察者的生活与事件的生命联系起来.如果没有完全了解你的程序,那就是我可以走得更远的链条了,但我认为你应该足以确定可观察的生命周期.

这实际上指出了标准.NET事件可能存在的潜在“内存泄漏”,对象使所有事件订阅者保持活动状态,从而导致您的第二个问题.如果您没有保留对IDisposable的引用,您将永远无法取消订阅该事件,并且您的对象将继续收到通知,即使您关闭与其相关的视图也是如此.如果事件源的寿命不长于视图,这可能不是问题,但我建议使用一次性.

关于这一点没有“un-Rx”,如果你愿意,Rx甚至还包括一个很好的类来替代List,System.Reactive.Disposables.CompositeDisposable.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读