2010-04-05 52 views
3

我使用IObservables和被動擴展創建多個異步Web請求。Rx:將多個IObservable Web請求拼接在一起

因此,這造成觀察到的,「GET」 web請求:

  var tweetObservalue = 
      from request in WebRequestExtensions.CreateWebRequest(outUrl + querystring, method) 
      from response in request.GetResponseAsync() 
      let responseStream = response.GetResponseStream() 
      let reader = new StreamReader(responseStream) 
      select reader.ReadToEnd(); 

而且我可以做

tweetObservable.Subscribe(response => dosomethingwithresponse(response)); 

什麼是執行與IObservables和LINQ具有多個異步Web請求的正確方法等到其他請求完成?

例如首先我想驗證用戶信息:create userInfoObservable,然後如果用戶信息是正確的我想更新統計數據,所以我得到updateStatusObservable然後如果狀態更新,我想創建friendshipObservable等。

此外,還有一個問題,我想同時執行Web調用,並且當所有完成時執行另一個observable,直到其他調用完成。

謝謝。

回答