RxJava - Reactive Extensions für die JVM - eine Bibliothek zum Erstellen asynchroner und ereignisbasierter Programme unter Verwendung beobachtbarer Sequenzen für die Java-VM.
Ich arbeite am Networking für meine App. Also habe ich beschlossen, Square's Retrofit auszuprobieren . Ich sehe, dass sie einfach unterstützenCallback @GET("/user/{id}/photo") void getUserPhoto(@Path("id") int id, Callback<Photo> cb); und RxJava Observable @GET("/user/{id}/photo")...
In RxJava stehen 5 verschiedene Scheduler zur Auswahl: instant () : Erstellt einen Scheduler und gibt ihn zurück, der die Arbeit am aktuellen Thread sofort ausführt. trampoline () : Erstellt einen Scheduler und gibt ihn zurück, der die Arbeit an dem aktuellen Thread in die Warteschlange...
Ich möchte den Unterschied zwischen wissen CompletableFuture, Futureund Observable RxJava. Was ich weiß ist, dass alle asynchron sind, aber Future.get() blockiert den Thread CompletableFuture gibt die Rückrufmethoden an RxJava Observable--- ähnlich wie CompletableFuturebei anderen Vorteilen (nicht...
Wann verwenden Sie mapvs flatMapin RxJava ? Angenommen, wir möchten Dateien, die JSON enthalten, Strings zuordnen, die JSON enthalten. Mit mapmüssen wir uns Exceptionirgendwie mit dem auseinandersetzen . Aber wie?: Observable.from(jsonFile).map(new Func1<File, String>() { @Override public...
Die rxjava-Dokumentdefinition von switchmap ist ziemlich vage und verweist auf dieselbe Seite wie flatmap. Was ist der Unterschied zwischen den beiden
Sind Java 8-Streams RxJava-Observablen ähnlich? Java 8-Stream-Definition: Klassen im neuen java.util.streamPaket bieten eine Stream-API zur Unterstützung von Operationen im Funktionsstil für Streams von
Ich habe mir das neue RX Java 2 angesehen und bin mir nicht ganz sicher, ob ich die Idee von verstehe backpressure mehr ... Mir ist bewusst, dass wir Observabledas nicht backpressureunterstützen und habenFlowable das hat es. Nehmen wir also anhand eines Beispiels an, ich habe flowablemit...
Kann jemand bitte den Unterschied zwischen Observable, Completable und Single in RxJava mit klaren Beispielen erklären? In welchem Szenario verwenden wir eines über das
Ich versuche, auf Retrofit 2.0 zu aktualisieren und RxJava in mein Android-Projekt aufzunehmen. Ich mache einen API-Aufruf und möchte den Fehlercode im Falle einer Fehlerantwort vom Server abrufen. Observable<MyResponseObject> apiCall(@Body body); Und im
Ich werde eine einfache get-Methode an meinen Server senden (es ist die Rails-App) und das Ergebnis mit RxJava und Retrofit abrufen. Was ich getan habe ist: Meine Schnittstelle: public interface ApiCall { String SERVICE_ENDPOINT = "https://198.50.214.15"; @GET("/api/post")
Ich verwende rxjava in meiner Android-App, um Netzwerkanforderungen asynchron zu verarbeiten. Jetzt möchte ich eine fehlgeschlagene Netzwerkanforderung erst nach Ablauf einer bestimmten Zeit wiederholen. Gibt es eine Möglichkeit, retry () auf einem Observable zu verwenden, aber erst nach einer...
TL; DR Wie konvertiere ich Task.whenAll(List<Task>)in RxJava? Mein vorhandener Code verwendet Bolts, um eine Liste asynchroner Aufgaben zu erstellen, und wartet, bis alle diese Aufgaben abgeschlossen sind, bevor andere Schritte ausgeführt werden. Im Wesentlichen wird eine erstellt...
Was sind die Vorteile zu nutzen Schedulers.newThread()vs Schedulers.io()in RetrofitNetzwerk - Anfrage. Ich habe viele Beispiele gesehen, die verwenden io(), aber ich möchte verstehen, warum. Beispielsituation: observable.onErrorResumeNext(refreshTokenAndRetry(observable))
Ich versuche folgende Funktion zu entschlüsseln: Subscription getCar(id, Observer<Car> observer) { return getCarDetails(id, new Observer<CarDetails> { @Override onNext(CarDetails details) { observer.onNext(details.getCar()); } }); } Ich habe eine gute Einführung in rxjava von...
Ich verkette asynchrone Operationen mit RxJava und möchte eine Variable nachgeschaltet übergeben: Observable .from(modifications) .flatmap( (data1) -> { return op1(data1); }) ... .flatmap( (data2) -> { // How to access data1 here ? return op2(data2); }) Es scheint ein...
In RxJava 1 gab es CompositeSubscription, aber das ist in RxJava2 nicht vorhanden. In rxJava2 gibt es etwas CompositeDisposable. Wie verwende ich CompositeDisposable oder Disposable in RxJava2?
Ich verwende RxJava in einem meiner Projekte, habe eine meiner Klassen mithilfe des Android Studio-Plugins in Kotlin konvertiert und in einem der Map flatMapLambda (Func1 in Java) sieht die Zwischenrückgabe wie folgt aus @Func1. Ich habe keine Ahnung, was das bedeutet.