C# 实现与现有.NET事件桥接简单实例

C# 实现与现有.NET事件桥接简单实例

 Rx提供了工厂方法，以便与.NET中的现有异步源桥接，以便您可以使用由任何类型的数据流提供的丰富的组合，过滤和资源管理功能。  本主题检查FromEventPattern运算符，它允许将.NET事件作为可观察序列“导入”到Rx中。  每次引发事件时，OnNext消息将被传递到可观察的序列。 然后，您可以像任何其他可观察序列一样处理事件数据。

  Rx并不旨在替换现有的异步编程模型，如.NET事件，异步模式或任务并行库。  但是，当您尝试编写事件时，Rx的工厂方法将为您提供在当前编程模型中找不到的方便。  这对于资源维护（例如，何时取消订阅）和过滤（例如，选择要接收什么类型的数据）尤其如此。  在本主题和后面的主题中，您可以了解这些Rx功能如何帮助您进行异步编程。

将.NET事件转换为Rx可观察序列

以下示例为鼠标移动事件创建一个简单的.NET事件处理程序，并在Windows窗体的标签中打印鼠标的位置。

  要将事件导入Rx，您可以使用FromEventPattern运算符，并提供将由要桥接的事件引发的EventArgs对象。  FromEventPattern运算符用于接收对象发送方和一些EventArgs的事件，并使用反射为您找到这些添加/删除方法。  然后，它将给定事件转换为具有EventPattern类型的可观察序列，该类型捕获发送方和事件参数。

  对于具有一个参数（非标准事件）的代理，可以使用FromEvent操作符，该操作符需要一对用于附加和分离处理程序的函数。

  在下面的示例中，我们将Windows窗体的鼠标移动事件流转换为可观察序列。 每次触发鼠标移动事件时，订阅者将收到OnNext通知。 然后，我们可以检查此类通知的EventArgs值，并获取鼠标移动的位置。

  注意，在这个示例中，move变成了一个可观察的序列，我们可以进一步操作。 使用LINQ运算符的查询可观察序列主题将向您展示如何将此序列投影到点类型的集合中并过滤其内容，以便应用程序只接收满足特定条件的值。

  事件处理程序的清理由Subscribe方法返回的IDisposable对象负责。 调用Dispose（通过在此示例中到达use-block的末尾来完成）将释放包括底层事件处理程序的序列正在使用的所有资源。 这本质上是代表您取消订阅活动。