ReactiveExtensions入门Rx操作符.doc

?? 在第一篇文章里讲过，Reactive Extensions(Rx)是对LINQ的一种扩展，其关键的特性在于他不是基于IEnumerable接口的，Rx是基于IObservable接口，这个接口用来迭代Observable集合。自然Observable集合是基于观察者模式设计的。Observable模式的关键在于被观察的对象有一些行为或者属性，观察者可以注册某些感兴趣的属性或者行为。当被观察者发生状态改变时，会通知观察者（通常是发起一个事件）。 ??? 观察者模式是发布和订阅模式(Publish and Subscribe Pattern)的一个子集，发布者可以产生一些告知其订阅者他的一些状态信息。在Rx中Observable集合有订阅者，简单来说，就是观察Observable集合的行为，称之为对象订阅了这一集合。 ??? 在Rx中，Observable集合在有新的元素添加到集合中去的时候，就会通知其订阅者。这是Observable集合和Enumerable集合的最本质区别。对象订阅Observable集合时，可能集合中的元素不存在，但是当集合中的元素在未来某一时刻到来时，会通知其订阅者。 ? 1. IObservable 和 IObserver接口 ? ??? 如前所述，Rx的关键在于Observable和其订阅者之间的关系。相比LINQ的IEnumerable和IEnumerator接口， Rx的关键接口为IObservable和IObserver。 ?? IObservable接口定义如下： public interface IObservableout T { IDisposable Subscribe(IObserverT observer); } ?? IObserver接口定义如下： public interface IObserverin T { void OnCompleted(); void OnError(Exception error); void OnNext(T value); } ??? 为了能够从Observable集合获取到通知，需要使用Subscribe方法传入一个Observer对象。注意到Subscribe方法返回IDisposable对象，这使得可以用来注销对Observable对象的注册。Reactive Extension会为我们处理所有这些注册和注销操作。如Observer接口定义那样，传入Subscribe方法中的Observer对象有三个方法。 ? 2. 创建Observables对象 ? ??? 为了演示使用不同的操作符创建Observables对象，需要建立一个项目。首先创建一个Windows Phone 项目，然后添加Microsoft.Phone.Reactive和System.Observable引用。 ??? 在主界面XAML文件中添一个名为Messages 的Listbox控件，并设置HorizontalAlignment 和VerticalAlignment属性，并将这两个属性设置为stretch，这个控件用来输出我们后面测试的数据。 Grid x:Name=ContentPanel Grid.Row=1 Margin=12,0,12,0 ListBox Name=Messages HorizontalAlignment=Stretch VerticalAlignment=Stretch Margin=10 / /Grid 然后再后台代码中创建一个Observer方法。该方法注册Observables并将结果输出到Listbox中来， 可以在Main方法中调用该方法。 private void Observe() { IObservableInt32 source = Observable.Return(42); IDisposable subscription = source.Subscribe( x=Messages.Items.Add(OnNext:+x), ex=Messages.Items.Add(OnError:+ex.Message), ()=Messages.Items.Add(OnComplated) ); } 下面我们演示以不同的方式返回Observables对象，只需要改变 IObservableInt32 source = Observable.Return(42); 这句代码即可。 使用Return方法返回Observable对象 ??? 上