2010-04-05 51 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,直到其他调用完成。

谢谢。

回答