rx-java

4Hitze

1Antwort

Observable.create vs Observable.fromAsync in RxJava

Ich verstehe, dass die Verwendung von Observable.createis discouraged in RxJava wegen fehlender Gegendruckunterstützung. Aus diesem Grund habe ich das neue Observable.fromAsync verwendet, um Callback-

2Hitze

2Antwort

Wie Observable.from (Zukunft) zu verwenden?

Ich lerne RxJava auf Android. Ich möchte es mit dem Netzwerk verwenden, also kann ich keine Sachen im Haupt-Thread machen. Ich habe den folgenden Code: final String RXTAG = "Rx"; Log.d(RXTAG, "Starti

0Hitze

1Antwort

RxJava: Erstellen von Klasseninstanz-Weiß, das auf Observables-Kette läuft

Ich habe einen Code, der RxJava verwendet, um eine XML-Datei zu analysieren. Immer wenn ein neues XML-Tag gelesen wird -> onNext (event_data) wird ausgelöst. Ich möchte eine Klassenentität auf "START_

1Hitze

1Antwort

"Super" Generika in Kotlin Funktionstypen auszudrücken?

Ich versuche, eine RxJava-Bibliothek zu portieren und Erweiterungsfunktionen in Kotlin zu nutzen. fun <T,R: MutableCollection<T>> Observable<T>.collectWhile(factory: (() -> R), condition: (R,T) -> Boo

0Hitze

2Antwort

Observable ist nicht asynchron

Ich lerne RxJava und testet ein Szenario, in dem ich Daten aus einer DB lese und dann in eine Warteschlange posten. Ich habe gerade eine Probe über den ganzen Prozess gemacht, aber ich finde nicht, da

3Hitze

1Antwort

Was ist die beste Vorgehensweise für die Rückgabe von Ergebnissen aus Observablen in einem Observable?

ich RxJava für mein Projekt bin mit und ich bin ein wenig mit diesem Stück Code verwirrt: @Override public Observable<Hexagon<T>> getHexagons() { return Observable.create(new OnSubscribe<He

-2Hitze

1Antwort

Web-Service mit unterschiedlichem Zeitintervall aufrufen?

Ich bin neu in Rx android.i versuche, Web-Service in verschiedenen Zeitintervallen aufzurufen. Anruf Api 4 Stunden alle 1 Minute für 30 Minuten, dann mit Rx android.if möglich lassen Sie mich alle 5 M

1Hitze

3Antwort

NoClassDefFoundError: rxscriptions.CompositeAbonnement

Ich habe ein Android-Projekt, wo ich rxjava und rxAndroid verwendet. Ich begann plötzlich, dass Absturz zu bekommen "NoClassDefFoundError: rx.subscriptions.CompositeSubscription" Ich habe versucht, es

1Hitze

2Antwort

RxJava: wie etwas wie doOnEmpty zu codieren?

Ich benutze mehrere Filter auf meiner Observable und ich würde Fälle am Ende der Filterung berichten, wenn das Ergebnis leer war. Ich kann es nicht am Ende der Verarbeitung tun, weil dies zu beobachte

13Hitze

2Antwort

Android Rxjava einer Variablen ändern abonnieren

I Observer Muster lerne, möchte ich meine beobachtbaren Spur einer bestimmten Variablen zu halten, wenn es seinen Wert ändert und einige Operationen zu tun, ich habe getan, so etwas wie: public class