我正在使用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.