C# Rx的主要接口深入理解

c# rx的主要接口深入理解

　iobservable / iobserver 接口在.net framework 4.0基类库中可用，并且它们包含在可以安装在.net 3.5，silverlight 3和4以及javascript中的包中。

iobservable/iobserver

　　rx将异步和基于事件的数据源公开为基于推送的可观察序列，由.net framework 4.0中的新iobservable 接口抽象。 这个iobservable 接口是用于基于拉的，可枚举集合的熟悉的ienumerable 接口的双重。 它表示可以观察到的数据源，这意味着它可以向任何有兴趣的人发送数据。 它维护一个代表这种感兴趣的监听器的依赖iobserver 实现的列表，并且自动地通知它们任何状态变化。

　　iobservable 接口的实现可以被视为类型t的元素的集合。因此，iobservable 可以被视为整数的集合，其中整数将被推送到订阅的观察者

　　如“什么是rx”中所述，推送模型的另一半由iobserver 接口表示，它表示通过订阅注册兴趣的观察者。 随后将项目从其订阅的可观察序列递送给观察者。

　　为了从observable集合接收通知，您使用iobservable的subscribe方法为其传递iobserver 对象。 作为对此观察者的回报，subscribe方法返回一个idisposable对象，作为订阅的句柄。 这允许您在完成后清理订阅。 在此对象上调用dispose将观察者从源分离，以便不再传递通知。 正如你可以推断，在rx中，不需要像.net事件模型中那样显式取消订阅事件。

　　观察者支持三个发布事件，由接口的方法反映。 当可观察的数据源具有可用的数据时，onnext可以被调用零次或更多次。 例如，用于鼠标移动事件的可观察数据源可以在每次鼠标移动时发出一个point对象。 其他两种方法用于指示完成或错误。

　　下面列出了iobservable / iobserver 接口。 　　

public interface iobservable<out t> 
{ 
  idisposable subscribe(iobserver<t> observer); 
} 
public interface iobserver<in t> 
{ 
  void oncompleted();// notifies the observer that the source has finished sending messages.
  void onerror(exception error); // notifies the observer about any exception or error.
  void onnext(t value);     // pushes the next data value from the source to the observer.
} 

　　rx还提供了subscribe扩展方法，以便您可以自己避免实现iobserver 接口。 对于可观察序列的每个发布事件（onnext，onerror，oncompleted），可以指定将调用的委托，如下面的示例所示。 如果不为事件指定操作，则将发生默认行为。

iobservable<int> source = observable.range(1, 5); //creates an observable sequence of 5 integers, starting from 1
idisposable subscription = source.subscribe(
              x => console.writeline("onnext: {0}", x), //prints out the value being pushed
              ex => console.writeline("onerror: {0}", ex.message),
              () => console.writeline("oncompleted"));

　　您可以将可观察序列（例如鼠标悬停事件的序列）看作是正常集合。 因此，您可以在集合上编写linq查询以执行过滤，分组，合成等操作。为了使可观察序列更有用，rx程序集提供了许多工厂linq运算符，因此您不需要自己实现任何这些 。 这将在使用linq运算符的查询可观察序列主题。 　

警告：

您不需要自己实现iobservable / iobserver 接口。 rx为您提供这些接口的内部实现，并通过observable和observer类型提供的各种扩展方法暴露它们。 有关详细信息，请参阅创建和查询可观察序列主题

 感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！