C# 實(shí)現(xiàn)與現(xiàn)有.NET事件橋接簡(jiǎn)單實(shí)例

　Rx提供了工廠方法，以便與.NET中的現(xiàn)有異步源橋接，以便您可以使用由任何類型的數(shù)據(jù)流提供的豐富的組合，過(guò)濾和資源管理功能。 本主題檢查FromEventPattern運(yùn)算符，它允許將.NET事件作為可觀察序列“導(dǎo)入”到Rx中。 每次引發(fā)事件時(shí)，OnNext消息將被傳遞到可觀察的序列。 然后，您可以像任何其他可觀察序列一樣處理事件數(shù)據(jù)。

　　Rx并不旨在替換現(xiàn)有的異步編程模型，如.NET事件，異步模式或任務(wù)并行庫(kù)。 但是，當(dāng)您嘗試編寫事件時(shí)，Rx的工廠方法將為您提供在當(dāng)前編程模型中找不到的方便。 這對(duì)于資源維護(hù)（例如，何時(shí)取消訂閱）和過(guò)濾（例如，選擇要接收什么類型的數(shù)據(jù)）尤其如此。 在本主題和后面的主題中，您可以了解這些Rx功能如何幫助您進(jìn)行異步編程。

將.NET事件轉(zhuǎn)換為Rx可觀察序列

以下示例為鼠標(biāo)移動(dòng)事件創(chuàng)建一個(gè)簡(jiǎn)單的.NET事件處理程序，并在Windows窗體的標(biāo)簽中打印鼠標(biāo)的位置。

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);
  }; 
}

　　要將事件導(dǎo)入Rx，您可以使用FromEventPattern運(yùn)算符，并提供將由要橋接的事件引發(fā)的EventArgs對(duì)象。 FromEventPattern運(yùn)算符用于接收對(duì)象發(fā)送方和一些EventArgs的事件，并使用反射為您找到這些添加/刪除方法。 然后，它將給定事件轉(zhuǎn)換為具有EventPattern類型的可觀察序列，該類型捕獲發(fā)送方和事件參數(shù)。

　　對(duì)于具有一個(gè)參數(shù)（非標(biāo)準(zhǔn)事件）的代理，可以使用FromEvent操作符，該操作符需要一對(duì)用于附加和分離處理程序的函數(shù)。

　　在下面的示例中，我們將Windows窗體的鼠標(biāo)移動(dòng)事件流轉(zhuǎn)換為可觀察序列。 每次觸發(fā)鼠標(biāo)移動(dòng)事件時(shí)，訂閱者將收到OnNext通知。 然后，我們可以檢查此類通知的EventArgs值，并獲取鼠標(biāo)移動(dòng)的位置。

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);
  }; 
}

　　注意，在這個(gè)示例中，move變成了一個(gè)可觀察的序列，我們可以進(jìn)一步操作。 使用LINQ運(yùn)算符的查詢可觀察序列主題將向您展示如何將此序列投影到點(diǎn)類型的集合中并過(guò)濾其內(nèi)容，以便應(yīng)用程序只接收滿足特定條件的值。

　　事件處理程序的清理由Subscribe方法返回的IDisposable對(duì)象負(fù)責(zé)。 調(diào)用Dispose（通過(guò)在此示例中到達(dá)use-block的末尾來(lái)完成）將釋放包括底層事件處理程序的序列正在使用的所有資源。 這本質(zhì)上是代表您取消訂閱活動(dòng)。

感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！