首页 > 代码库 > 探索Rx的主要接口

探索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 one rror(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类型提供的各种扩展方法暴露它们。 有关详细信息,请参阅创建和查询可观察序列主题
 原文地址:https://msdn.microsoft.com/en-us/library/hh242974(v=vs.103).aspx 基本基于google翻译的
  返回

<script type="text/javascript"> $(function () { $(‘pre.prettyprint code‘).each(function () { var lines = $(this).text().split(‘\n‘).length; var $numbering = $(‘
    ‘).addClass(‘pre-numbering‘).hide(); $(this).addClass(‘has-numbering‘).parent().append($numbering); for (i = 1; i <= lines; i++) { $numbering.append($(‘
  • ‘).text(i)); }; $numbering.fadeIn(1700); }); }); </script>

    探索Rx的主要接口