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,直到其他调用完成。
谢谢。
应该在这里发表您answser,不是链接 – 2012-10-01 20:01:11