C# Rx的主要接口深入理解
C#Rx的主要接口深入理解
IObservable/IObserver接口在.NETFramework4.0基类库中可用，并且它们包含在可以安装在.NET3.5，Silverlight3和4以及JavaScript中的包中。
IObservable/IObserver
Rx将异步和基于事件的数据源公开为基于推送的可观察序列，由.NETFramework4.0中的新IObservable接口抽象。这个IObservable接口是用于基于拉的，可枚举集合的熟悉的IEnumerable接口的双重。它表示可以观察到的数据源，这意味着它可以向任何有兴趣的人发送数据。它维护一个代表这种感兴趣的监听器的依赖IObserver实现的列表，并且自动地通知它们任何状态变化。
IObservable接口的实现可以被视为类型T的元素的集合。因此，IObservable可以被视为整数的集合，其中整数将被推送到订阅的观察者
如“什么是Rx”中所述，推送模型的另一半由IObserver接口表示，它表示通过订阅注册兴趣的观察者。随后将项目从其订阅的可观察序列递送给观察者。
为了从observable集合接收通知，您使用IObservable的Subscribe方法为其传递IObserver对象。作为对此观察者的回报，Subscribe方法返回一个IDisposable对象，作为订阅的句柄。这允许您在完成后清理订阅。在此对象上调用Dispose将观察者从源分离，以便不再传递通知。正如你可以推断，在Rx中，不需要像.NET事件模型中那样显式取消订阅事件。
观察者支持三个发布事件，由接口的方法反映。当可观察的数据源具有可用的数据时，OnNext可以被调用零次或更多次。例如，用于鼠标移动事件的可观察数据源可以在每次鼠标移动时发出一个Point对象。其他两种方法用于指示完成或错误。
下面列出了IObservable/IObserver接口。
publicinterfaceIObservable{ IDisposableSubscribe(IObserver observer); } publicinterfaceIObserver { voidOnCompleted();//Notifiestheobserverthatthesourcehasfinishedsendingmessages. voidOnError(Exceptionerror);//Notifiestheobserveraboutanyexceptionorerror. voidOnNext(Tvalue);//Pushesthenextdatavaluefromthesourcetotheobserver. }
Rx还提供了Subscribe扩展方法，以便您可以自己避免实现IObserver接口。对于可观察序列的每个发布事件（OnNext，OnError，OnCompleted），可以指定将调用的委托，如下面的示例所示。如果不为事件指定操作，则将发生默认行为。
IObservablesource=Observable.Range(1,5);//createsanobservablesequenceof5integers,startingfrom1 IDisposablesubscription=source.Subscribe( x=>Console.WriteLine("OnNext:{0}",x),//printsoutthevaluebeingpushed ex=>Console.WriteLine("OnError:{0}",ex.Message), ()=>Console.WriteLine("OnCompleted"));
您可以将可观察序列（例如鼠标悬停事件的序列）看作是正常集合。因此，您可以在集合上编写LINQ查询以执行过滤，分组，合成等操作。为了使可观察序列更有用，Rx程序集提供了许多工厂LINQ运算符，因此您不需要自己实现任何这些。这将在使用LINQ运算符的查询可观察序列主题。
警告：
您不需要自己实现IObservable/IObserver接口。Rx为您提供这些接口的内部实现，并通过Observable和Observer类型提供的各种扩展方法暴露它们。有关详细信息，请参阅创建和查询可观察序列主题
感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！