rx-java

0Hitze

1Antwort

Android Espresso wartet rxjava .delay von beobachtbaren

Ich habe einen Server Anruf mit Retrofit + RxJava gemacht, dass ich sein Verhalten auf dem Bildschirm testen möchten. Das Ziel besteht darin, vor dem Aufruf ein Ladebild zu setzen und nach dem Einblen

0Hitze

1Antwort

Schwerwiegende Ausnahme: java.lang.IllegalStateException: Schwerwiegende Ausnahme auf Scheduler.Worker-Thread geworfen

Ich bekomme einen Absturz, während ich einen Netzwerkanruf mit Retrofit mache. Hier ist mein Stacktrace. Fatal Exception: java.lang.IllegalStateException: Fatal Exception thrown on Scheduler.Worker th

0Hitze

1Antwort

mit Rxjava mit Nachrüstung und Realm

Ich möchte die zwischengespeicherten Daten in Realm verwenden, dann aktualisieren Sie die Daten vom Server mit Retrofit. ich es geschafft, dass durch die folgenden: public void getNotifications() {

3Hitze

1Antwort

RxJava Timer, der für immer wiederholt und kann neu gestartet und gestoppt werden jederzeit

In android i Timer verwenden Aufgabe auszuführen, die alle 5 Sekunden und beginnt nach 1 Sekunde auf diese Weise wiederholt: Timer timer = new Timer(); timer.scheduleAtFixedRate(new TimerTask() {

1Hitze

1Antwort

Wie zwei Abonnements in RXJava/Android

verbinden Wie kann ich zwei Abonnements binden wie: 1) Retrofit & RX, die in recyclerView gezeigt von Strings JSON in Liste umwandelt. 2) Und Jack Whartons RxBinding-Bibliothek reagiert auf Änderungen

2Hitze

1Antwort

RxJavaPlugins.getInstance ist

veraltet ich meine Disponenten für die Prüfung außer Kraft setzen mit: RxJavaPlugins.getInstance().registerSchedulersHook(object : RxJavaSchedulersHook() { override fun getIOScheduler() = Schedul

2Hitze

3Antwort

RxJava onErrorResumeNext Aufrufe java.io.InterrupedIOException

Ich habe ein Problem mit RxJava onErrorResumeNext Operator. Ich möchte den Speicherort abrufen, dann Daten vom Server abrufen (mit Retrofit) hängt vom Speicherort ab, aber wenn kein Speicherort (Fehle

0Hitze

2Antwort

Wie kann ich mehrere beobachtbare Aufrufe asynchron aufrufen, aber gleichzeitig vor und nach diesen Aufrufen einige Berechnungen durchführen?

Ich bin neu bei RxJava. Ich habe ein paar Jersey RxJava Kunden, die Observables zurückgeben. Ich muss einen Anruf tätigen, um einige Daten zu erhalten, diese Daten werden die Eingabe für meine nächste

0Hitze

1Antwort

PublishSubject on fireNext wenn abonniert

Ich versuche, einen Proxy für meine Modelle mit RxJava zu erstellen, dieser Proxy lässt andere für Änderungen im Modell abonnieren. Hier ist eine vereinfachte Version meiner Proxy: class MyModelProxy

3Hitze

1Antwort

Unterschied zwischen der Verwendung von Immediate Scheduler und keine Verwendung von Scheduler überhaupt

Was ist der Unterschied zwischen Immediate scheduler verwenden und nicht verwenden? Observable.create(subscriber -> subscriber.onNext(new Object())).subscribeOn(Schedulers.immediate()).subscribe(); /