Suchergebnisse für Anfrage "reactive-programming"
RxJs: Wie wird eine Schleife basierend auf dem Status des Observablen erstellt?
Ich versuche, RxJs dazu zu bringen, eine Observable in meinem Stream zu durchlaufen, bis sie sich in einem bestimmten Zustand befindet, und dann den Stream weiterlaufen zu lassen. Insbesondere konvertiere ich eine synchrone do / while-Schleife ...
Unerklärliche mangelnde Leistungsverbesserung bei Verwendung von RxJava Observables in Webanwendungen
Ich führe einige Tests durch, um festzustellen, ob die Verwendung reaktiver APIs auf der Basis von Observables einen echten Vorteil bietet, anstatt die herkömmlichen zu blockieren. Das ganze Beispiel ist verfügbar auf ...
Dynamisches Erstellen von Registerkarten mit Plots in Glanz, ohne vorhandene Registerkarten neu zu erstellen
Ich möchte dynamische Registerkarten erstellen, bei denen jedes Mal, wenn der Benutzer auf eine Schaltfläche klickt, eine neue Registerkarte erstellt wird. Jede Registerkarte verfügt über denselben Inhalt und eine Reihe von Widgets, mit denen der ...
Calling setState im Render ist nicht vermeidbar
as @ React-Dokument gibt an, dass dasrender Funktion sollte @ serei was bedeutet, dass es nicht @ verwenden sollthis.setState drin. Ich glaube jedoch, wenn der Zustand von 'remote' abhängt, d. h. Ergebnis eines Ajax-Aufrufs. Die einzige Lösung ...
Wenn Sie ein Abonnement abbestellen möchten
Ich habe eine Frage zum Abbestellen einer Observable. Ich habe zwei Codes und bin mir nicht sicher, welcher besser ist. Beispiel 1 -> Abonnent abbestellen, sobald der Stream beendet ist: Subscriber<String> subscriber = new Subscriber<String>() ...
Wie verwende ich Observable.fromCallable () mit einer aktivierten Ausnahme?
Observable.fromCallable() eignet sich hervorragend zum Konvertieren einer einzelnen Funktion in eine Observable. Aber wie gehen Sie mit überprüften Ausnahmen um, die von der Funktion ausgelöst werden könnten? Die meisten Beispiele, die ich ...
Holen Sie sich den neuesten Wert eines Observable und senden Sie ihn sofort aus
Ich versuche, den neuesten Wert eines gegebenen @ zu erhaltObservable und lasse es sofort ausgeben, sobald es aufgerufen wird. Als Beispiel sei der folgende Code angeführt: return Observable.just(myObservable.last()) .flatMap(myObservable1 -> { ...
Chaining RxJs Observables in Angular 2
Ich habe eine TypeScript-Funktion in meiner Angular 2-App, die eine Observable zurückgibt, um Web-API-Daten an den Consumer zurückzusende public getApiData(): Observable { let readySource = Observable.from('no', 'no', 'ready'); let dataSource = ...
RxJS warten, bis das Versprechen gelöst ist
Ich bin mir immer noch sicher, dass es sich um eine reaktive Programmierung handelt, daher bin ich mir ziemlich sicher, dass dies sehr einfach ist, aber die Anzahl der Stream-Transformationen ist für Anfänger ziemlich überwältigend. Ich ...
Begrenzung gleichzeitiger Anforderungen mit Rx und SelectMany
Ich habe eine Liste mit URLs von Seiten, die ich gleichzeitig mit @ herunterladen möchtHttpClient. Die Liste der URLs kann groß sein (100 oder mehr!) Ich habe derzeit diesen Code: var urls = new List<string> { @"http:\\www.amazon.com", ...