Suchergebnisse für Anfrage "rx-java"
RxJava: Wie mache ich ein Fetch-Once-and-Reuse-Observable?
Bei jedem App-Start habe ich ein Retrofit Observable, das den Benutzernamen des Benutzers von einem Server abruft. Ich möchte diesen Wert für jeden nachfolgenden Teilnehmer verwenden, aber jedes Mal, wenn ich subscribe () aufrufe, wird der Wert ...
Wie wandle ich eine verschachtelte Liste von Doppelwerten mit RxJava in eine Java-Klasse um?
In meinem Android-Client erhalte ich diese JSON-Daten von einem Backend: [ [ 1427378400000, 553 ], [ 1427382000000, 553 ] ]Hier ist die Routine, die die Daten tatsächlich lädt. Ich benutze RxAndroid [https://github.com/ReactiveX/RxAndroid] und ...
Wie implementiere ich observLatestOn in RxJava (RxScala)?
Ich versuche das @ zu implementier ObserveLatestOn [https://social.msdn.microsoft.com/Forums/en-US/bbcc1af9-64b4-456b-9038-a540cb5f5de5/how-do-i-ignore-allexceptthelatest-value-when-my-subscribe-method-is-running?forum=rx>] Operator in RxJava ...
Liefern Sie den ersten Artikel sofort, 'entprellen' Sie die folgenden Artikel
Betrachten Sie den folgenden Anwendungsfall: notwendig, den ersten Artikel so schnell wie möglich zu liefernmüssen debounce folgenden Ereignissen mit 1 Sekunde TimeoutIch implementierte schließlich einen benutzerdefinierten Operator basierend ...
Differenz zwischen Java 8-Streams und RxJava-Observablen
Sind Java 8-Streams ähnlich wie RxJava Observables? Java 8 Stream Definition: Klassen im neuenjava.util.stream -Paket bietet eine Stream-API zur Unterstützung von Operationen im funktionalen Stil für Streams von Elementen.
Verwenden Sie RxJava und Retrofit, um die Liste zu durchlaufen und die Ergebnisse basierend auf Unterabfragen zu erweitern.
Ich verwende Retrofit und denke, dass rxjava (mit retrolambda) für den folgenden Ablauf gut geeignet ist: get Liste der Widgets (http)für jedes Widget a) eine Liste von Artikeln (http) für den angegebenen Widget-Typ erhalten b) speichere alle ...
Kette zwei nachrüstbare Observables mit RxJava
Ich möchte 2 Netzwerkanrufe nacheinander ausführen. Beide Netzwerkanrufe geben Observable zurück. Zweiter Aufruf verwendet Daten vom erfolgreichen Ergebnis des ersten Aufrufs, Methode im erfolgreichen Ergebnis des zweiten Aufrufs verwendet Daten ...
Wie man den Fehler auth0 403 behandelt, ohne überall spezifischen Code hinzuzufügen (Retrofit / okhttp / RxAndroid)
Ich verwende Auth0, das mir ein JWT (JSON-Web-Token) und ein Auffrischungs-Token gibt. Ich verwende dieses JWT in den http-Headern, um mit meinem Backend zu kommunizieren. Es kann vorkommen, dass der Server mir ein @ gi403, wenn entschieden ...
RxJava: "java.lang.IllegalStateException: Nur ein Abonnent erlaubt!"
Ich verwende RxJava, um die normalisierte Autokorrelation für einige Sensordaten in Android zu berechnen. Seltsamerweise löst mein Code eine Ausnahme aus ("java.lang.IllegalStateException: Nur ein Abonnent zulässig!") Und ich bin mir nicht ...
Wie Aufgabe mit Retrofit und rxjava abbrechen
Ich habe Ruhe api. @Get("/serveraction") public Observable<String> myRequest(@Query("Data") String data);Ich weiß, dass okhttp eine Abbruchfunktion hat (nach Anfrageobjekt, nach Tag), aber ich weiß nicht, wie ich es mit Retrofit und rxjava ...