Tag: rx-java
RxJava – Reactive Extensions für die JVM – Bibliothek für das erstellen von asynchronen und event-basierten Programmen mit beobachtbaren Sequenzen für die Java VM.
RxJavaCallAdapterFactory kann nicht umgewandelt werden-Fabrik
3 Antworten
Ich versuche, Retrofit 2 und RxJava nach der Anleitung in diesem https://inthecheesefactory.com/blog/retrofit-2.0/en Im Abschnitt "RxJava Integration mit CallAdapter "wird erläutert, wie die Verwendung RxJava mit retrofit - Retrofit retrofit = new Retrofit.Builder() .baseUrl("http://api.nuuneoi.com/base/") .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .build(); Jedoch
Vergleich von Java-reaktiven frameworks
1 Antworten
Sehe ich sehr viele frameworks/Bibliotheken, die behaupten, Sie kann dabei helfen, reaktive Anwendungen in Java, wie zum Beispiel: Akka, Vert.x, RxJava, Reaktor, QBit, etc. Scheinen Sie haben unterschiedliche Ansätze, Funktionen, Vorteile, Nachteile, etc. Ich konnte nicht finden,
RxJava - Mit flatmap, wenn eine Rückkehr könnte null sein
3 Antworten
Let ' s verwenden Sie diese Klasse zum Beispiel: public static class CurrentUser{ public static Observable<User> get(){ //code basically returns the currently logged in User object //but sometimes there may not be a logged in user }
Fallback Beobachten für RxJava
6 Antworten
Ich bin auf der Suche nach einem besseren Weg, um zu erreichen, eine einfache Beobachtbare fallback-system für leere Ergebnisse bei der Verwendung von RxJava. Die Idee ist, dass, wenn eine lokale Abfrage für eine Reihe von Daten-Ergebnisse
Die ordnungsgemäße Verwendung von Retrofit + RxJava ist combineLatest
3 Antworten
Ich möchte 2 Netzwerk-Aufrufe asynchron - ich bin mit Retrofit+RxJava um dies zu erreichen. Diese Logik ist aus einem einfachen Runner-Klasse zu testen, die Lösung. HINWEIS: Dies betrifft meist RxJava auf der server-Seite. Mein code sieht wie
Reich + Retrofit + Rxjava
3 Antworten
Ich versuche, herauszufinden, einen Weg, um zu sparen meine Analysierten Objekte von retro in Reich durch rxjava zu beobachten. Nun habe ich einen API-Aufruf: fetchCatalogData().subscribeOn(Schedulers.io()) .subscribe(data -> saveToRealm(); ) Das funktioniert nicht, denn entweder bin ich mit
RxJava: Aufruf onError ohne Abschluss / Abmeldung
3 Antworten
Habe ich den folgenden code (*), die polling Verwendung eines scheduler, der ruft rekursiv die mitgelieferte beobachten. (*) inspiriert von https://github.com/ReactiveX/RxJava/issues/448 Ist dies korrekt funktioniert, wenn ich nur an die onNext event zu den Abonnenten. Aber wenn
Bei der Verwendung von zip() anstelle von zipWith() RxJava
1 Antworten
Gibt es eine semantische Differenz in paarweisen Kombinationen mit zip() vs. zipWith() in RxJava? Ist die Wahl zwischen dem statischen zip und die .zipWith rein stilistisch? InformationsquelleAutor Stuckzilla | 2017-08-08
Beobachtbar ist.empty() bewirkt, dass java.util.NoSuchElementException: die Sequenz enthält keine Elemente
1 Antworten
Ich bin mit Retrofit-2.0.0-beta2 mit RxJava 1.0.14. Ich handle Fehler dieser Art, denn ich muss zum ausführen von code in doFinally: .onErrorResumeNext(Observable.empty()); Aber wenn ich eine http-Antwort mit einem Fehler (401 zum Beispiel) meine app stürzt ab,
Was ist der Unterschied zwischen den Schedulern.io() und Scheduler.Berechnung()
2 Antworten
In couchbase, Observablen Was ist der Unterschied zwischen: Planer.io() Und Planer.Berechnung() InformationsquelleAutor Osama Abdulsattar | 2015-10-27
RxJava Kombinieren Sequenz Von Anfragen
5 Antworten
Das Problem Habe ich zwei Apis. Api-1 gibt mir eine Liste der Elemente und Api-2-gibt mir mehr detaillierte Informationen für die einzelnen Elemente habe ich aus Api-1. Die Art, wie ich es gelöst bisher Ergebnisse in schlechte
Beobachtbar ist.nur vs Single in RxJava
1 Antworten
Ich bin neu RxJava und RxAndroid und versuchen zu verstehen, den Unterschied zwischen Observable.just und Single. Es sieht aus wie jeder ist so konzipiert, Strahlen Sie eine Position für Ihre Beobachter. Hier ist der code meiner einfachen
So aktualisieren Sie UI von Android service mit RxJava/RxAndroid
2 Antworten
Ich habe eine Gebundene Dienstleistung, die zuständig für das herunterladen von Dateien und so es weiß der Download-status/Fortschritt. Und die UI (- Fragment oder die Aktivität zu zeigen/update-download-Fortschritt aus dem Dienst. Eigentlich denke ich, der gemeinsame Weg
Herunterladen und schreiben einer Datei mit Retrofit-und RxJava
1 Antworten
Ich bin das herunterladen einer pdf-Datei mit Nachrüstung, die Art, wie ich bin herunterladen es ist von Blöcken. Ich benutze die Content-Range header zu erhalten, eine Reihe von bytes, dann muss ich schreiben, diese bytes auf einem
Herunterladen von Dateien mit OkHttp, Okio und RxJava
1 Antworten
Ich versuche, die download-Dateien mit OkHttp und schreiben auf den Datenträger mit Okio. Auch ich habe eine rx beobachtbar für diesen Prozess. Es funktioniert, aber es ist deutlich langsamer als das, was ich zuvor (Koush ' s
RXJava2: richtige pattern-chain-retrofit-Anforderungen
2 Antworten
Ich bin relativ neu in RXJava im Allgemeinen (eigentlich nur begann, es zu benutzen mit RXJava2), und die meisten Unterlagen, die ich finden kann, neigt dazu, RXJava1; ich kann in der Regel übersetzen zwischen den beiden jetzt,
Default-Scheduler für rxjava auf Android
4 Antworten
Ich bin mit Retrofit zurück rxjava Beobachtbar ist für meine async-Netz telefonieren. Finde ich wiederholte für mich selbst die folgende Anrufung: someApiCall().subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()) Scheint, wie ich bin immer Anmeldung auf der IO-thread und die Beobachtung auf die Android-Haupt-thread.
Wie behandeln Sie Ausnahmen, die ausgelöst durch Beobachter onNext in RxJava?
1 Antworten
Betrachten Sie das folgende Beispiel: Observable.range(1, 10).subscribe(i -> { System.out.println(i); if (i == 5) { throw new RuntimeException("oops!"); } }, Throwable::printStackTrace); Diese Ausgaben zahlen von 1 bis 5 und dann druckt die Ausnahme. Was ich erreichen will
RxJava 2 übergeordnete IO-scheduler unit test
4 Antworten
Ich versuche zum testen der folgenden RxKotlin/RxJava 2 code: validate(data) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .flatMap { ... } Ich versuche zu überschreiben, die Planer wie folgt: //Runs before each test suite RxJavaPlugins.setInitIoSchedulerHandler { Schedulers.trampoline() } RxAndroidPlugins.setInitMainThreadSchedulerHandler { Schedulers.trampoline() }
Einzelne RxJava entpacken von Objekt
2 Antworten
Ich denken kann, zwei Möglichkeiten, um den Wert von Einzelnen Single<HotelResult> observableHotelResult = apiObservables.getHotelInfoObservable(requestBody); final HotelResult hotelResults = new HotelResult[1]; singleHotelResult .subscribe(hotelResult -> { hotelResults[0] = hotelResult; }); Oder final HotelResult hotelResult = singleHotelResult .toBlocking() .value(); So
Fehlerbehandlung für RV-observablen
1 Antworten
Mein use-case ist: ich bekomme eine Liste von permalinks, und ausgeben müssen, die zwei REST-Anfragen pro permalink, um Ihre Daten in teilen. Wenn beide Anfragen sind zurück, die ich Zusammenführen möchten Ihre Infos zusammen und tun etwas
Beobachter.onError-firing off uneinheitlich
2 Antworten
Ich bin mit Retrofit auf meine API wie folgt: public interface UserService { ... @POST("/user/login") public Observable<User> register(@Body() User user); } Hier ist, wie ich Zugriff auf meine API: mUserService.register(user) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer<User>() { @Override public
Wie handle paging mit RxJava?
4 Antworten
Ich bin auf der Suche in der Umstellung meiner android app zu verwenden Rxjava für Netzwerk-Anforderungen. Ich habe derzeit Zugriff auf einen webservice ähnlich: getUsersByKeyword(String query, int limit, int offset) Als ich verstehen es, Observablen sind ein
Erstellen Beobachten, ohne die Verwendung zu Beobachten.erstellen
2 Antworten
Ich bin mit RxJava in meine Android-app und ich möchte das laden der Daten aus der Datenbank. In dieser Weise, erstelle ich eine neue Observable mit Observable.create() gibt eine Liste von EventLog public Observable<List<EventLog>> loadEventLogs() { return
Um leere Antwort mit retrofit-und rxjava 2.x
3 Antworten
Bei der Verwendung rxjava 1.x ich verwendet, um zurück Observable<Void> zu handhaben leere Antwort von retrofit: @POST( "login" ) Observable<Void> getToken( @Header( "Authorization" ) String authorization, @Header( "username" ) String username, @Header( "password" ) String password );
Wie zip-paar observablen in Kotlin Sprache mit RxAndroid
2 Antworten
Habe ich ein problem. Ich bin ein beginer in RxJava/RxKotlin/RxAndroid, und dont verstehen, einige Funktionen. Zum Beispiel: import rus.pifpaf.client.data.catalog.models.Category import rus.pifpaf.client.data.main.MainRepository import rus.pifpaf.client.data.main.models.FrontDataModel import rus.pifpaf.client.data.product.models.Product import rx.Observable import rx.Single import rx.lang.kotlin.observable import java.util.* class MainInteractor { private
Eleganten Weg, um index des filters oder der erste mit RX-Java
3 Antworten
Ich bin nur üben RX Java und wollte die position in einem array für Elemente, die einem filter entsprechen. Ich sehe keinen offensichtlichen Weg, es zu tun. Ich war auf der Suche auf vielleicht das zippen einer
Android Studio hinzufügen rxjava Bibliothek
3 Antworten
Betrachten Sie folgende Projektstruktur: MainProject -.idea -.grandle -src -SubProject --libs //I created this folder manually ---rxjava-core-0.16.0-sources.jar --src ---main //+ all the sources --build.grandle --SubProject.iml -build.grandle -//other files Ich heruntergeladen habe die .jar von http://search.maven.org/#search%7Cga%7C1%7Cg%3A%22com.netflix.rxjava%22%20AND%20a%3A%22rxjava-core%22 (sources.jar) - aber
Wie die Rückkehr Wert mit RxJava?
1 Antworten
Wir betrachten diese situation. Wir haben einige Klassen, die eine Methode liefert einen Wert: public class Foo() { Observer<File> fileObserver; Observable<File> fileObservable; Subscription subscription; public File getMeThatThing(String id) { //implement logic in Observable<File> and return value which
Erhalten Sie die neuesten Wert einer Beobachtbaren und emittieren es immeditely
3 Antworten
Ich versuche, den aktuellen Wert eines bestimmten Observable und bekommen es zu emittieren sofort, sobald es aufgerufen wird. Angesichts des folgenden code als Beispiel: return Observable.just(myObservable.last()) .flatMap(myObservable1 -> { return myObservable1; }) .map(o -> o.x) //Here I
Warten für die parallele RX-Abonnenten zu vervollständigen
3 Antworten
Ich bin auf der Suche nach der besten Methode zu warten, bis asynchrone Aufgaben zu erledigen, die im rx-java. Als eine gemeinsame Beispiel, sagen, dass es eine Funktion bekommt eine Liste von id 's aus einem lokalen
RxJava onErrorResumeNext()
1 Antworten
Habe ich zwei observablen (mit Namen A und B der Einfachheit halber) und einen Abonnenten. So, die Abonnenten abonniert, und wenn es ist ein Fehler auf A dann B (das ist die fallback -) kicks in. Nun,
Verhindern OnErrorNotImplementedException
3 Antworten
Möchte ich erreichen, dass wenn ich Anrufe der Obervable.subscribe(Action1) Methode, es nicht zu werfen OnErrorNotImplementedException überall, aber wenn ich Anruf Obervable.subscribe(Action1, Action1), die zweite Aktion wird aufgerufen, wenn ein Fehler ausgelöst wird als normal. Ich habe zwei
Verhalten von onNext und onComplete
3 Antworten
Ich habe eine Observable, die etwas tut, ohne die Notwendigkeit, geben einen Wert ein. Auch ich habe eine Liste von Objekten, ich will das Beobachten, mit zu arbeiten. Also für alle Elemente in dieser Liste: doSomething() Observable.from(uris)
Retrofit ist nicht in der Lage zu erstellen, rufen adapter
2 Antworten
Dies ist mein Interface UserService @GET(Constants.Api.URL_LOGIN) String loginUser(@Field("email") String email, @Field("password") String pass, @Field("secret") String secret, @Field("device_id") String deviceid, @Field("pub_key") String pubkey, @Field("device_name") String devicename); In der Aktivität rufe ich retrofit = new Retrofit.Builder() .baseUrl(Constants.Api.URL_BASE) .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
Wie zu warten, bis asynchrone Beobachtbaren abzuschließen
3 Antworten
Ich versuche zu bauen, ein Beispiel für die Verwendung rxjava. Die Probe sollte orchestrieren eine ReactiveWareService und ein ReactiveReviewService retruning eine WareAndReview composite. ReactiveWareService public Observable<Ware> findWares() { return Observable.from(wareService.findWares()); } ReactiveReviewService: reviewService.findReviewsByItem does a ThreadSleep to
Wie zu verwenden zu Beobachten.fromCallable() eine checked Exception?
2 Antworten
Observable.fromCallable() ist ideal für die Umwandlung einer Funktion in eine Beobachtbare. Aber wie gehst du mit Ausnahmen geprüft werden könnten, ausgelöst durch die Funktion? Meisten der Beispiele, die ich gesehen habe, Lambda-Ausdrücke und "einfach funktionieren". Aber wie
Unit-Test-Applikation für android-mit retrofit-und rxjava
6 Antworten
Habe ich entwickelt, eine android-app, ist mit retrofit mit rxJava, und jetzt habe ich ' m, die versuchen, die unit-tests mit Mockito, aber ich weiß nicht, wie mock die api-Antworten, um tests, die nicht tun, die echte
Retrofit und RxJava: Wie kombinieren zwei Anfragen und erhalten Sie Zugang zu den beiden Ergebnissen?
2 Antworten
Muss ich zwei Anfragen für Dienstleistungen und kombinieren Ergebnisse: ServiceA() => [{"id":1,"name":"title"},{"id":1,"name":"title"}] ServiceB(id) => {"field":"value","field1":"value"} Derzeit, ich habe es geschafft, um die Ergebnisse zu kombinieren, aber ich muss noch passieren id als parameter an die ServiceB und
Wie zu verwenden RxJava Intervall-Operator
3 Antworten
Lerne ich über RxJava-operator, und ich fand diese code unten nicht alles drucken: public static void main(String args) { Observable .interval(1, TimeUnit.SECONDS) .subscribe(new Subscriber<Long>() { @Override public void onCompleted() { System.out.println("onCompleted"); } @Override public void onError(Throwable e)
Wie zu verwenden RxJava combineLatest Betreiber mit mehr als 9 observablen
4 Antworten
Ich bin mit RxJava und ich will verbinden 12 verschiedene observablen mit Hilfe des operators combineLatest. Sah ich ein Funktionsprototyp, die eine Liste von observablen und eine Implementierung von FuncN aber ich bin mir nicht sicher, wie
Wie erstellen Sie Beobachten von der Funktion?
3 Antworten
Möchte ich eine Funktion aufrufen (synchron) und dann mit dessen Rückgabewert als eine erste emission (anschließend Verkettung einigen anderen Anbietern, die daraus resultierenden messbaren). Ich soll zum aufrufen dieser Funktion im Abonnement, ich kann also nicht einfach
Wer einen Beobachtbaren in RxJava
2 Antworten
Habe ich eine beobachtbare, dass bei der Durchführung eines download. Aber ich will Abbrechen, der beobachtbar ist, wenn ich auf einen button zu klicken. Wie ist das möglich? Danke. Können Sie einige code, was du bereits versucht
Durchlaufen der Liste mit RxJava/RxAndroid
4 Antworten
Ich bin neu RxJava/RxAndroid aber ich bin stecken geblieben mit meinem Anwendungsfall. Ich versuche, um die Iteration eines List<A> konvertieren jedes A in eine B asynchron (da braucht es Aufruf der Datenbank) und mein Observer informiert werden
wie um zu überprüfen, ob Beobachtbare leer ist oder einen booleschen Wert zurückgibt
1 Antworten
können sagen, ich habe beobachtbar, dass call-rest-api-service, und speichern Sie dann das Ergebnis in der Datenbank: public Observable<Boolean> initDB() { return this.restApi.feedsEntityList() .flatMap(feedEntityList -> this.mNewsCache.saveFeeds(feedEntityList) ); } speichern Beobachtbare ausführen der Datenbank speichern und sollte return true
Wie behandeln onError-innen RxJava. Ich bin immer "OnErrorNotImplementedException"
3 Antworten
In meiner app verwende ich ReactiveLocationProvider Bibliothek (link). Ich subscribe for updates " in der onCreate-Methode. Es funktioniert, wenn das Gerät online ist, aber wenn ich schalte mein WLAN aus, und warten Sie für die nächste Standortaktualisierung
Sortieren-array in RxJS
2 Antworten
RxJava hat eine Methode toSortedList(Comparator comparator) wandelt einen Fluss von Objekten in eine Liste von Objekten sortiert, die von einem Komparator. Wie kann ich erreichen das gleiche in JavaScript mit RxJS und erhalten eine Beobachtbare mit einem
RxJava: Wie zum extrahieren Objekt von der observable?
2 Antworten
Ich glaube, das ist eine dumme Frage, aber ich konnte keine Antwort für eine Weile, also werde ich Sie Fragen, sorry 🙂 So, ich brauche eine Funktion, die Folgendes macht: 1) Ruft eine andere Funktion zu erstellen,
RxJava; Wie zu emittieren observablen synchron
4 Antworten
Möchte ich synchron gibt zwei Wahrnehmbare Objekte (asynchron), eine nach der anderen, wo es gibt die ersten beobachteten Objekt emittiert. Falls die erste fehlschlägt, sollte es nicht emittieren die zweiten. Sagen wir, wir haben eine Wahrnehmbare Zeichen,
RxJava - Wie man Beobachter zu blockieren
1 Antworten
Ich würde gerne meine Observable zu blockieren, bis der Vorgang abgeschlossen ist, und fahren Sie mit der nächsten Methode aufruft etc. Werfen Sie einen Blick auf diese code: import rx.Observable; import rx.android.schedulers.AndroidSchedulers; import rx.functions.Action1; import rx.functions.Func1; Observable