rx-java

RxJava - Reaktive Erweiterungen für die JVM - eine Bibliothek zum Erstellen von asynchronen und ereignisbasierten Programmen mit beobachtbaren Sequenzen für die Java VM.
3
Antworten

So ketten Sie die groupBy () -Methoden von mehreren RxJava wie groupBy (). groupBy ()

Gegebene Eingabe: %Vor% Gruppiere die Zahlen durch ungerade oder gerade und dann um weniger als oder größer als 5. Erwartete Ausgabe: %Vor% Die Reihenfolge der Ausgabe ist nicht eingeschränkt. Ich verwende jetzt den folgenden Ansat...
30.01.2015, 07:14
2
Antworten

Reaktive Streams - Batch mit Timeout

Ich bin dabei, eine selbst erstellte Bibliothek für die Protokollverarbeitung zu ersetzen, die ReactiveStreams mit io.projectreactor sehr nahe kommt. Das Ziel besteht darin, den von uns gepflegten Code zu reduzieren und neue Funktionen zu nut...
12.07.2017, 10:48
1
Antwort

Kann ein Rx Observable problemlos Ausnahmen in einem Operator behandeln und fortfahren?

d. h. durch Übergeben der Fehlerbedingung und nicht Anhalten des gesamten Observable? Meine Beobachtungsliste beginnt mit einer vom Benutzer angegebenen Liste von Paketverfolgungsnummern aus allgemeinen Zustelldiensten (FedEx, UPS, DHL us...
19.01.2015, 19:17
2
Antworten

RxJava verschmelzen entprellte und nicht entlarvte Observablen

Ich habe zwei Observable: Observable O (open): Datei mit einigen Inhalten in textview geöffnet Beobachtbare E (edit): Datei Inhalt in Textansicht bearbeitet Ich möchte E beobachtbar machen und es mit O beobachtbar verbinden. %Vor% D...
21.09.2016, 17:18
4
Antworten

Unit Test - Verifiziere, dass Observable abonniert ist

Ich habe den Java-Code wie folgt %Vor% und ich möchte verify das folgende Observable wird .subscribe() Ich habe versucht, getObservable() und verify vorzuspielen %Vor% Aber es gibt einen Fehler %Vor% Ich denke, es ist...
09.11.2016, 04:47
1
Antwort

Richtiger Weg kein Netzwerk mit Retrofit und RX-Java zu behandeln

Ich möchte überprüfen, ob das Handy mit dem Internet verbunden ist, bevor ich meinen rx Retrofit-Service anrufe. Wenn nicht verbunden, möchte ich eine falsche Antwort zurückgeben, die einen Fehler enthält. Ich habe mit der folgenden Lösung mi...
25.02.2015, 15:24
1
Antwort

Seltsame Lebenszyklus-Callbacks, die beim Eintritt in den Multi-Window-Modus geordnet sind

Ich habe ein Problem mit RxJava, Retrofit und Multi-Window-Modus ... Ich rufe unsere eigene API mit Retrofit in einer Aktivität (der eigentliche Code ist ein bisschen komplexer als das): %Vor% Wenn die App im "normalen" Modus ist (Vollbildmo...
03.04.2017, 10:23
3
Antworten

Warum gibt mein RxJava Observable nicht aus oder vervollständigt es nur, wenn es blockiert?

Hintergrund Ich habe eine Reihe von RxJava Observables (entweder von Jersey Kunden oder Stubs mit Observable.just(someObject) ) generiert. Alle sollten genau einen Wert ausgeben. Ich habe einen Komponententest, der alle Jersey-Kunden ausspi...
13.12.2015, 23:21
2
Antworten

Was verursacht HTTP-FEHLER: java.net.SocketException: Socket geschlossen?

Ich verwende okhttp und Retrofit für eine meiner Anwendungen und ich habe viele Anfragen, die mit RxJava an verschiedenen Threads arbeiten. Manchmal habe ich SocketException für jede Anforderung erhalten und danach kann keine Anfrage den Server...
17.11.2016, 10:49
4
Antworten

RxJava und parallele Ausführung von Observer-Code

Ich habe den folgenden Code mit RxJava Observable API: %Vor% Meine Erwartung war, dass der Beobachtungscode, d. h. der Code innerhalb der subscribe () -Methode, parallel ausgeführt wird, nachdem ich den Berechnungsplaner spezifiziert habe. S...
16.02.2016, 07:00