rx-android

1Hitze

1Antwort

Retrofit2 return Observable mit 1 Objekt für jeden onNext

Ich habe begonnen, mit Retrofit2, Rxjava und GSON und ich wunderte mich etwas. Zur Zeit habe ich so etwas wie dieses: @GET("roster/byid/{userId}") Observable<List<Contact>> roster(@Path("userId")

1Hitze

1Antwort

Transform AmazonS3 senden an RX android beobachtbar

Wie würde ich diesen asynchronen Anruf zu RX Android zu transformieren und die Fähigkeit haben, um es auf andere Anrufe zu ketten? Momentan verwende ich EventBus, um zu informieren, dass Senden erfolg

2Hitze

1Antwort

Mockito - MissingMethodInvocationException

Ich versuche zu testen, dass ein API-Aufruf auf dem richtigen Scheduler geplant ist und auf dem Hauptthread beobachtet. @RunWith(PowerMockRunner.class) @PrepareForTest({Observable.class, AndroidSched

0Hitze

2Antwort

Warum Schedulers.io() manchmal in mainthread ausgeführt?

Ich benutze RxAndroid statt Thread selbst. Und ich hatte es auf io Thread abonniert, aber es läuft manchmal im Haupt-Thread. manchmal wurde das Protokoll im Hauptthread gedruckt. Observable.from(bitma

2Hitze

1Antwort

HashMap-Werte mit RxJava transformieren

Gibt es einen Weg, mit 'Weg' meine ich mit rx-Operatoren, um jeden HashMap-Wert zu transformieren (den hashmap-Schlüssel als Wertfeld zu setzen) und in eine neue Hashmap oder ArrList zu gelangen? Obse

0Hitze

1Antwort

combineLatest() -Funktion auf mainThread

Ich möchte 2 Observablen kombinieren und führen "kombinieren Funktion" auf AndroidSchedules.mainThread(). Ich habe .observeOn (AndroidSchedules.mainThread()) hinzugefügt, bekomme aber immer noch "java

4Hitze

4Antwort

Schwerwiegende Ausnahme auf Scheduler geworfen. Worker-Thread mit Retrofit 2 und Rx

Dies ist der Code, den ich verwenden, um HTTP-Aufruf zu machen. Ich kann den Fehler nicht reproduzieren, sondern Bugsnag sagt mir, dass einige Benutzer diesen Fehler erhalten: java.lang.IllegalStateEx

7Hitze

3Antwort

Holen Sie sich den neuesten Wert eines Observable und emittieren Sie es sofort

Ich versuche, den neuesten Wert eines gegebenen Observable zu bekommen und es sofort emittieren, sobald es aufgerufen wird. In Anbetracht der Code unten als Beispiel: return Observable.just(myObservab

0Hitze

1Antwort

Erhalten der anfänglichen Emission eines Observable später in seinem Baum

Angesichts einer heißen Observable<String> myObservable, die Werte in unregelmäßigen Abständen emittieren. Ich möchte in der Lage sein zu flatMap ein obs1Observable und je nach Ergebnis von obs1 ich f

6Hitze

1Antwort

RxJava Break Chain auf Conditional

Ich erstelle eine beobachtbare Sequenz und ich bin im Grunde auf der Suche nach einer schönen Möglichkeit, die Kette zu brechen, wenn eine Bedingung nicht erfüllt ist. Im Idealfall könnten wir in dies