Rx: Mettendo insieme le richieste multiple web IObservable

Question

Sto creando molteplici richieste asincrone web utilizzando IObservables e le estensioni reattivi.

Quindi, questo crea osservabile per "GET" richiesta 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();

E posso fare

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

Qual è il modo corretto di eseguire molteplici richieste asincrone web con IObservables e LINQ che devono aspettare fino a quando le altre richieste sono state finito?

Per esempio prima vorrei verificare informazioni all'utente:. Creare userInfoObservable, quindi se informazioni utente sia corretto che voglio statistiche aggiornamento in modo da ottenere updateStatusObservable allora se lo stato viene aggiornato Vorrei creare friendshipObservable e così via

Inoltre questione bonus, v'è un caso in cui vorrei eseguire chiamate web contemporaneamente e quando tutti sono finiti eseguire un'altra osservabile che saranno fino a quando le altre chiamate sono finiti.

Grazie.

Answer 1

Questo è stato risposto qui

http: // sociale .msdn.microsoft.com / Forum / it / rx / thread / 17471ab5-1ec2-4ea1-a2b3-a24cf6191820