Rx: Piecing zusammen mehrere IObservable Webanfragen
-
24-09-2019 - |
Frage
Ich bin mit IObservables und reaktiven Erweiterungen mehr asynchronen Web-Anfragen zu erstellen.
So schafft dies beobachtbare für "GET" Web-Anfrage:
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();
Und ich kann tun
tweetObservable.Subscribe(response => dosomethingwithresponse(response));
Was ist der richtige Weg, um mehr asynchronen Web-Anfragen mit IObservables und LINQ der Ausführung, die warten müssen, bis andere Anfragen abgeschlossen wurden?
Zum Beispiel zuerst würde ich gerne die Benutzerinformationen überprüfen:. UserInfoObservable erstellen, dann, wenn der Benutzer Informationen korrekt ich Update Statistiken will, damit ich updateStatusObservable erhalte dann, wenn Status aktualisiert ich friendshipObservable erstellen möchte und so weiter
Auch Bonus-Frage gibt es einen Fall, in dem Ich mag würde Web-Anrufe gleichzeitig ausführen und wenn alle fertig sind andere beobachtbare auszuführen, die noch bis andere Anrufe beendet sind.
Danke.
Lösung
Dies wurde hier beantwortet