本主题介绍主要反应扩展 (Rx) 接口，用于表示可观测序列并订阅它们。
IObservable<T>/IObserver<T> 接口在 .NET Framework 4.0 基类库中提供，它们位于 .NET 3.5、Silverlight 3 和 4 以及 Javascript 中安装的包中。
IObservable<T>/IObserver<T>
Rx 将异步和基于事件的数据源公开为 .NET Framework 4.0 中新 IObservable T> 接口抽象的基于推送的<可观察序列。 此 IObservable<T> 接口是熟悉的 IEnumerable<T> 接口的双重接口，用于基于拉取的可枚举集合。 它表示可以观察到的数据源，这意味着它可以将数据发送给任何感兴趣的人。 它维护表示此类相关侦听器的依赖 IObserver<T> 实现的列表，并自动通知它们任何状态更改。
IObservable<T> 接口的实现可视为 T 类型元素的集合。因此，可将 IObservable<int> 视为整数集合，其中整数将推送到订阅的观察器。
如 What is Rx 中所述，推送模型的另一半由 IObserver<T> 接口表示，该接口表示通过订阅注册兴趣的观察者。 随后，从它订阅的可观测序列中将项交给观察程序。
为了从可观测集合接收通知，可以使用 IObservable 的 Subscribe 方法向它递给 IObserver<T> 对象。 作为此观察者的回报，Subscribe 方法返回充当订阅句柄的 IDisposable 对象。 这使你可以在完成后清理订阅。 对此对象调用 Dispose 会将观察程序与源分离，以便不再传递通知。 可以推断，在 Rx 中，无需像在 .NET 事件模型中那样显式取消订阅事件。
观察程序支持三个发布事件，这些事件由接口的方法反映。 当可观测数据源具有可用数据时，可以调用 OnNext 零次或多次。 例如，用于鼠标移动事件的可观测数据源可以在每次移动鼠标时发送一个 Point 对象。 其他两种方法用于指示完成或错误。
下面列出了 IObservable<T>/IObserver<T> 接口。
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<T> 接口。 对于可观测序列 (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<T>/IObserver<T> 接口。 Rx 提供这些接口的内部实现，并通过 Observable 和 Observer 类型提供的各种扩展方法公开它们。 有关详细信息，请参阅 创建和查询可观测序列 主题。