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

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

2021-12-28 16:47aofengdaxia C#

这篇文章主要介绍了C# 实现与现有.NET事件桥接简单实例的相关资料,需要的朋友可以参考下

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

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

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

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

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

				?

									using System.Linq;

									using System.Windows.Forms;

									using System.Reactive;

									using System.Reactive.Linq;

									using System;

									using WinForm;

									using System.Reactive.Disposables;

									class Program {

									  static void Main() 

									  {

									     var lbl = new Label(); 

									     var frm = new Form { Controls = { lbl } }; 

									     frm.MouseMove += (sender, args) =>

									     {

									       lbl.Text = args.Location.ToString();

									     };

									     Application.Run(frm);

									  }; 

									}

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

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

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

				?

									using System.Linq;

									using System.Windows.Forms;

									using System.Reactive;

									using System.Reactive.Linq;

									using System;

									using WinForm;

									using System.Reactive.Disposables;

									class Program {

									  static void Main() 

									  {

									     var lbl = new Label(); 

									     var frm = new Form { Controls = { lbl } }; 

									     IObservable<EventPattern<MouseEventArgs>> move = Observable.FromEventPattern<MouseEventArgs>(frm, "MouseMove");

									     move.Subscribe(evt => { 

									               lbl.Text = evt.EventArgs.Location.ToString(); 

									            }) ;

									     Application.Run(frm);

									  }; 

									}