我创建使用IObservables和反应性扩展多个异步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请求的正确方法是什么?

例如首先我想验证用户信息:创建userInfoObservable,那么如果用户信息是正确的我想更新统计信息,因此我得到updateStatusObservable那么如果状态更新,我想创建friendshipObservable等

此外奖金问题,存在这样的情况,我想同时执行网络的呼叫的情况下,当所有被完成执行另一个可观察到的,这将直到其他呼叫结束。

感谢您。

许可以下: CC-BY-SA归因
不隶属于 StackOverflow
scroll top