rx-java

RxJava - Reaktive Erweiterungen für die JVM - eine Bibliothek zum Erstellen von asynchronen und ereignisbasierten Programmen mit beobachtbaren Sequenzen für die Java VM.
2
Antworten

Wie erstelle ich ein Observable in Android?

Ich möchte einen einfachen In-Memory-Cache erstellen, um Observables auszuprobieren. Ich bin jedoch steckengeblieben, weil ich nicht verstehe, wie man ein Observable erstellt. Dies ist der Code, den ich bisher bekommen habe: %Vor% In der Met...
07.03.2016, 16:51
1
Antwort

RxJava - Verketten von Anfragen und Aktualisieren der Benutzeroberfläche

Das Problem, das ich habe, ist das. Ich muss einige Anfragen an den Server ausführen. Jede nächste Anfrage hängt vom vorherigen Ergebnis ab. Sie sehen so aus (abgekürzt): %Vor% Ich habe eine einzige Observable mit einer flatMap erstellt, die...
07.03.2017, 17:10
1
Antwort

Eine Warteschlange von Hintergrundaufgaben in rxjava

Ist es möglich, eine Warteschlange von Hintergrundaufgaben mit rxjava zu implementieren? Ich brauche die Möglichkeit, eine Aufgabe jederzeit hinzuzufügen und nur eine Aufgabe gleichzeitig auszuführen. Ich habe PublishSubject ausprobiert, aber...
16.07.2015, 07:35
4
Antworten

Rx - Teilen Sie den Strom in Segmente (Listen) nach Bedingung

Ich habe einen RX-Producer, der einen Stream von Strings wie folgt erzeugt (vereinfachte Version des realen Streams): A1 A2 A3 B1 B2 C1 C2 C3 C4 C5 C6.... Der Strom ist endlos, aber geordnet. Nachdem die Strings, die mit A ausgehen,...
17.09.2015, 07:58
2
Antworten

Was ist die korrekte Art der Transaktionsverwaltung in RxJava Services?

Ich habe vor kurzem begonnen, mit RxJava zu experimentieren und stieß dabei auf eine Präsentation eines Netflix-Technikers, der vorgeschlagen hat, unsere Business-APIs auf Observable APIs zu verschieben, zum Beispiel: %Vor% Ich habe jedoch k...
13.12.2015, 11:48
2
Antworten

Proguard und RxAndroid V1.1.0

Ich kann nicht scheinen, dass Proguard mit der RxAndroid v1.1.0-Bibliothek arbeitet. Vorher habe ich v1.0.1 benutzt und das funktionierte gut mit der folgenden Regel. %Vor% Aber nach dem Upgrade auf v1.1.0 von rxAndroid und auch mit RxJav...
16.12.2015, 15:04
1
Antwort

rxjava und clojure asynchrony Mysterium: Futures Versprechen und Agenten, oh mein

Ich entschuldige mich im Voraus für die Länge dieser Notiz. Ich verbrachte viel Zeit damit, es kürzer zu machen, und das war so klein, wie ich es bekommen konnte. Ich habe ein Rätsel und wäre dankbar für Ihre Hilfe. Dieses Mysterium kommt von...
01.06.2013, 02:20
3
Antworten

Verhalten von onNext und onComplete

Ich habe ein Observable, das etwas tut, ohne einen Wert ausgeben zu müssen. Außerdem habe ich eine Liste von Objekten, mit denen das Observable arbeiten soll. Also für alle Elemente in dieser Liste: doSomething () %Vor% Und die Methode, die...
23.07.2015, 10:52
1
Antwort

Lazy fetching von paginierten Objekten mit RxJava

Ich bin fast an RxJava verkauft worden, was ein perfekter Begleiter für Retrofit ist, aber ich kämpfe bei der Migration meines Codes in ein gemeinsames Muster: um Bandbreite zu sparen, möchte ich (paginierte) Objekte aus meiner Webservice nach B...
10.02.2015, 09:39
1
Antwort

Fehlerbehandlung für gezippte Observables

Mein Anwendungsfall ist: Ich erhalte eine Liste von Permalinks und muss pro Permalink zwei REST-Anfragen ausgeben, um ihre Daten in Teilen zu erhalten. Wenn beide Anfragen zurück sind, möchte ich ihre Informationen zusammenführen und etwas damit...
13.06.2015, 19:21