是.net中的一個擴展方法動作的無效擴展<T>

Question

我有兩個採用Action回調的asynchronouse方法。我想知道在Rx中是否有擴展行爲？

我的目標是等到兩個回調被調用，然後做一些處理？

Answer 1

這是Jesse and my upcoming book，但在這裏你去，這是一個免費的東西：

public Func<T1, IObservable<TRet>> FromCallbackPattern<T1, TRet>(Action<T1, Action<TRet>> originalMethod) 
{ 
    return new Func<T1, IObservable<TRet>>((param1) => { 
     var subject = new AsyncSubject<TRet>(); 

     try { 
      return originalMethod(param1, (result) => { 
       subject.OnNext(result); 
       subject.OnCompleted(); 
      }); 
     } catch (Exception ex) { 
      subject.OnError(ex); 
     } 

     return subject; 
    }); 
} 

這裏是你如何使用它：

// Here's a sample method that follows the callback pattern 
public void DownloadPageTextAsync(string url, Action<string> callback); 

var dlPageRx = FromCallbackPattern(DownloadPageTextAsync); 

dlPageRx("http://www.jesseliberty.com") 
    .Subscribe(pageText => Console.WriteLine(pageText));