rx-android

21Hitze

3Antwort

Wann kann ich ein Abonnement abbestellen?

Ich habe eine Frage bezüglich der Abmeldung eines Observablen. Ich habe zwei Codes und bin mir nicht sicher, welches besser ist. Beispiel 1 -> die Teilnehmer abmelden, sobald der Strom beendet hat: Su

0Hitze

1Antwort

RxAndroid Intervall mit FlatMap Lockruf zweimal statt einmal

CODE heartBeatSub = Observable.interval(HEARTBEAT_INTERVAL, TimeUnit.SECONDS) .flatMap(new Func1<Long, Observable<Notification<Response>>>() { @Override public Observable<Notifi

16Hitze

1Antwort

Observable läuft auf Haupt-Thread, obwohl SubscribeOn() auf einem anderen Thread aufgerufen wird

Ich habe ein seltsames Problem in einer meiner Aktivitäten. Wenn ich von der Aufnahme eines Fotos/Videos zurückkomme, zeige ich in meinem onActivityResult einen Dialog an, in dem der Benutzer die Kame

7Hitze

1Antwort

Wie Antwort Antwort Körper mit RxAndroid und Retrofit 2?

Ich benutze Retrofit 2 (Beta 4), und ich wollte von der Verwendung der Standard Call Antwort auf die RxAndroid Observable Antwort zu bewegen. Es ist mir gelungen, die meisten meiner Anrufe mit einem e

8Hitze

2Antwort

Wie erstelle ich ein Observable in Android?

Was ich tun möchte, ist einen einfachen In-Memory-Cache zu erstellen, nur um Observables auszuprobieren. Ich bin jedoch steckengeblieben, weil ich nicht verstehe, wie man ein Observable erstellt. Dies

0Hitze

1Antwort

RxJava - single Observable sofort ausführbar - warum?

Ich habe einen sehr einfachen RXJava Emitter. Es ist eigentlich ein publishSubject, aber seine Aufgabe besteht darin, Integer in Strings umzuwandeln und ein UI-Element nachträglich zu aktualisieren, w

4Hitze

2Antwort

rxjava interval() Zeit nach einem Ereignis zurücksetzen

Ich mache eine Android-App mit RxJava, in einer der Seite, ich habe eine Schaltfläche, wenn gedrückt, wird die Seite eine Aktualisierung vornehmen. Und ich möchte auch eine automatische Aktualisierung

3Hitze

1Antwort

RxJava, erste Artikel erhalten, wenn vorhanden

Ich versuche, den ersten Artikel aus einer Liste mit RxJava zu bekommen. Ich will jedoch nicht, dass es einen Fehler gibt, wenn das Element nicht existiert. Stattdessen möchte ich selbst damit umgehen

1Hitze

1Antwort

Datenübertragung zwischen Anfragen mit Retrofit + RxJava

Ich entschied mich, Retrofit 2.0 + RxJava in meinem Projekt zu verwenden. Das Hauptproblem ist, dass ich nicht vollständig verstehe, wie es sein sollte. Zuerst alle Anfragen an meine Server-API, und j

18Hitze

5Antwort

Wie Sie Observable.interval stoppen und fortsetzen, die Ticks ausgeben

Dies wird alle 5 Sekunden ein Häkchen ausgeben. Observable.interval(5, TimeUnit.SECONDS, Schedulers.io()) .subscribe(tick -> Log.d(TAG, "tick = "+tick)); es zu stoppen Sie alle verwenden könn