Suchergebnisse für Anfrage "rx-java"
RxJava - Nur gegen Von
Ich erhalte die gleiche Ausgabe bei Verwendung vonObservable.just vsObservable.from im folgenden Fall: public void myfunc() { //swap out just for from here and i get the same results,why ? Observable.just(1,2,3).subscribe(new ...
RxJava-Wiederholung basierend auf der Logik
Hier ist der Fall, ich habe API-Aufruf usign Retrofit, der möglicherweise aufgrund eines Netzwerkfehlers fehlschlägt. Wenn dies fehlschlägt, wird eine Fehlermeldung mit einem Wiederholungsbutton angezeigt. Wenn der Benutzer den Wiederholungsknopf ...
Wie kann ich mit RxJava einen Wert zurückgeben?
Betrachten wir diese Situation. Wir haben eine Klasse mit einer Methode, die einen Wert zurückgibt: public class Foo() { Observer<File> fileObserver; Observable<File> fileObservable; Subscription subscription; public File getMeThatThing(String ...
Downloaden und schreiben Sie eine Datei mit Retrofit und RxJava
Ich lade eine PDF-Datei mit Nachrüstung herunter, die Art und Weise, wie ich sie herunterlade, ist blockweise. Ich verwende dasContent-Range Header, um einen Bereich von Bytes zu erhalten, dann muss ich diese Bytes auf ein @ schreibfile das ...
Interaktionen in rxjava-Abonnenten überprüfen
Stellen Sie die Situation in einem MVP-Muster dar, in der Ihr Moderator einen Dienst abonniert, der einen Beobachter zurückgibt: public void gatherData(){ service.doSomeMagic() ...
AndroidRX - Methode im Hintergrund ausführen
Ich habe eine einfache Aktivität mit der Infinity Progres-Leiste erstellt, und ich versuche, eine zeitaufwendige Methode mit RxJava auszuführen, um zu verhindern, dass der UI-Thread blockiert wird, aber jedes Mal, wenn der UI-Thread blockiert ...
rxJava Schedulers Anwendungsfälle
n RxJava gibt es 5 verschiedene Scheduler [http://reactivex.io/RxJava/javadoc/rx/schedulers/Schedulers.html] wählen von sofortig(: Erstellt einen Scheduler und gibt diesen zurück, der die Arbeit sofort für den aktuellen Thread ...
Wie mache ich einen rekursiven, beobachtbaren Aufruf in RxJava?
Ich bin ziemlich neu bei RxJava [https://github.com/ReactiveX/RxJava] (und das reaktive Paradigma im Allgemeinen), bitte nehmen Sie Kontakt mit mir auf. ngenommen, ich habe diesesNews und dieses verschachtelteComment Datenstruktur public class ...
Periodische HTTP-Anforderungen mit RxJava und Retrofit
Ist es möglich, RxJava / RxAndroid und Retrofit zu verwenden, um regelmäßige http-Anforderungen zum Aktualisieren von Daten alle x Sekunden auszuführen? erzeit verwende ich einen IntentService und einen rekursiven Handler / Runnable, der alle x ...
Rx Java mergeDelayError funktioniert nicht wie erwartet
Ich verwende RxJava in und Android-Anwendung mit RxAndroid. Ich benutze mergeDelayError [http://reactivex.io/documentation/operators/merge.html], um zwei Retrofit-Netzwerkaufrufe zu einer beobachtbaren Funktion zu kombinieren, die ausgestrahlte ...