如何將此代碼轉換爲異步等待？

Question

我有很多這樣的代碼：

 var feed = new DataFeed(host, port); 
     feed.OnConnected += (conn) => 
     { 
      feed.BeginLogin(user, pass); 
     }; 
     feed.OnReady += (f) => 
     { 
      //Now I'm ready to do stuff. 
     }; 

     feed.BeginConnect(); 

正如你所看到的，我用做異步操作的常用方式。如何更改此代碼以使用async await？最好是這樣的：

public async void InitConnection() 
{ 
    await feed.BeginConnect(); 
    await feed.BeginLogin(user, pass); 

    //Now I'm ready 
} 

Answer 1

您可以使用TaskCompletionSource<T>將您的EAP（基於事件的異步模式）封裝到任務中。目前還不清楚如何處理錯誤，並在數據傳送專線類取消操作，那麼您就需要修改這個代碼，並添加錯誤處理（sample）：

private Task ConnectAsync(DataFeed feed) 
{ 
    var tcs = new TaskCompletionSource<object>(); 
    feed.OnConnected += _ => tcs.TrySetResult(null); 
    feed.BeginConnect(); 
    return tcs.Task; 
} 

private Task LoginAsync(DataFeed feed, string user, string password) 
{ 
    var tcs = new TaskCompletionSource<object>(); 
    feed.OnReady += _ => tcs.TrySetResult(null); 
    feed.BeginLogin(user, pass); 
    return tcs.Task; 
} 

現在你可以使用以下方法：

public async void InitConnection() 
{ 
    var feed = new DataFeed(host, port); 
    await ConnectAsync(feed); 
    await LoadAsync(feed, user, pass); 
    //Now I'm ready 
} 

注 - 您可以將這些異步方法移至DataFeed類。但是，如果您可以修改DataFeed，那麼最好使用TaskFactory.FromAsync將APM API包裝爲任務。

不幸的是，沒有非通用的TaskCompletionSource這將返回非通用的Task所以，通常解決方法是使用Task<object>。