Suchergebnisse für Anfrage "rx-java"
Behandlung von Netzwerkfehlern in Retrofit 2 mit RxJava
Ich benutze Retrofit2 mit RxJava. Also mein Anruf sieht ungefähr so aus wie subscriptions.add(authenticateUser(mReq, refreshRequest) .observeOn(Schedulers.io()) .subscribeOn(Schedulers.io()) .subscribe(authResponseModel -> { ...
RxJava: Bedingtes Anwenden von Operatoren auf eine Observable ohne Unterbrechung der Kette
Ich habe eine Kette von Operatoren auf einem RxJava, die beobachtet werden können. Ich möchte in der Lage sein, einen von zwei Operatoren abhängig von einem Booleschen Wert anzuwenden, ohne die "Kette zu unterbrechen". Ich bin relativ neu in Rx ...
Single Observable with Multiple Subscribers
Ich habe einObservable<<List<Foo>> getFoo() das von einem Retrofit-Service erstellt wird und nach dem Aufruf des.getFoo() -Methode muss ich es mit mehreren Abonnenten teilen. Aufruf des.share() -Methode bewirkt jedoch, dass der Netzwerkaufruf ...
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 ...
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 ...
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 ...
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 ...
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 -> { ...
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) -> ...