3

我正在使用 IObservables 和响应式扩展创建多个异步 Web 请求。

因此,这为“GET”网络请求创建了 observable:

            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 请求的正确方法是什么,这些请求必须等到其他请求完成?

例如,首先我想验证用户信息:创建 userInfoObservable,然后如果用户信息正确,我想更新统计信息,所以我得到 updateStatusObservable,然后如果状态更新,我想创建friendshipObservable 等等。

还有一个额外的问题,有一种情况我想同时执行网络调用,当所有调用都完成后执行另一个可观察的,直到其他调用完成。

谢谢你。

4

1 回答 1

0

这是在这里回答的

http://social.msdn.microsoft.com/Forums/en/rx/thread/17471ab5-1ec2-4ea1-a2b3-a24cf6191820

于 2010-04-06T17:48:17.413 回答