Suchergebnisse für Anfrage "rx-java"
Korrekter Ablauf in RxJava mit Retrofit und Realm
Ich implementiere die Netzwerk-API mit der Kombination von RxJava und Retrofit und verwende Realm als meine Datenbank. Ich habe es ziemlich zum Laufen gebracht, aber ich frage mich, ob es der richtige Ansatz und Ablauf der Ereignisse ist. Also, ...
Queue wie Subject in RxJava
Ich suche nach einem Betreff (oder ähnlichem), der: Kann Elemente empfangen und in einer Warteschlange oder einem Puffer speichern, wenn keine Abonnenten vorhanden sindobald wir einen Abonnenten haben, werden alle Artikel verbraucht und nie ...
Paginate Beobachtbare Ergebnisse ohne Rekursion - RxJava
Ich habe ein ziemlich standardmäßiges API-Paginierungsproblem, das Sie mit einer einfachen Rekursion lösen können. Hier ist ein Beispiel: public Observable<List<Result>> scan() { return scanPage(Optional.empty(), ImmutableList.of()); } private ...
Firebase offline no CompletionListener on setValue
Ich habe diese Codebasis, in der ich einen Wert festgelegt habe. Im Offlinemodus wird erfolgreich geschrieben, aber die CompletionListener.onComplete-Rückruffunktion wird nicht aufgerufen. newOrderRef.setValue(order, (firebaseError, firebase) -> ...
Holen Sie sich den neuesten Wert eines Observable und senden Sie ihn sofort aus
Ich versuche, den neuesten Wert eines gegebenen @ zu erhaltObservable und lasse es sofort ausgeben, sobald es aufgerufen wird. Als Beispiel sei der folgende Code angeführt: return Observable.just(myObservable.last()) .flatMap(myObservable1 -> { ...
RxAndroid - Wiederholung bei Klick beobachtbar
Ich verwende rxAndroid und rxKotlin in meiner Android-App, um Netzwerkanforderungen asynchron zu verarbeiten. Jetzt möchte ich eine fehlgeschlagene Netzwerkanfrage erst wiederholen, nachdem ich auf die Snackbar-Schaltfläche geklickt habe. Mein ...
RxJava teilt die Emissionen eines Observable auf mehrere Abonnenten
Ich habe das folgende Problem: Ich habe ein Observable, das einige Arbeiten ausführt, aber andere Observables benötigen die Ausgabe dieses Observable, um zu funktionieren. Ich habe mehrmals versucht, dasselbe Observable zu abonnieren, aber im ...
Anfragen in Retrofit + RxJava bearbeiten
Ich habe 2 APIs, die ich der Reihe nach anfordern und deren Daten in SQLite speichern möchte. Zunächst möchte ich eine Anfrage an die API stellenA und speichern Sie seine Daten in der SQL-Tabellea. Dann senden Sie eine Anfrage an APIB und ...
Android Retrofit 2 + RxJava: endlosen Stream anhören
Kann ich Retrofit + RxJava verwenden, um einen endlosen Stream anzuhören? Zum Beispiel der Twitter-Stream. Was ich habe, ist das: public interface MeetupAPI { @GET("http://stream.meetup.com/2/rsvps/") Observable<RSVP> getRSVPs(); } MeetupAPI api ...
Wie verwende ich Observable.fromCallable () mit einer aktivierten Ausnahme?
Observable.fromCallable() eignet sich hervorragend zum Konvertieren einer einzelnen Funktion in eine Observable. Aber wie gehen Sie mit überprüften Ausnahmen um, die von der Funktion ausgelöst werden könnten? Die meisten Beispiele, die ich ...