Suchergebnisse für Anfrage "rx-java"
InterruptedIOException bei Verwendung von Retrofit2 mit rx bei retryOn
Ich benutze retrofit 2 mit rx-android Ich habe ziemlich komplexe Wiederholungslogik, was teilweise funktioniert. Ich habe irrelevanten Code abgeschnitten, um ihn zu vereinfachen. Hier ist es public class RetryWithDelay implements ...
RxJava - Endlose Streams beenden
Ich erforsche reaktive Programmierung und RxJava. Es macht Spaß, aber ich habe ein Problem, auf das ich keine Antwort finden kann. Meine grundsätzliche Frage...
Android RxJava, nicht blockierend?
Ich habe verstanden, dass rxjava-android Operationen auf einem separaten Thread ausführt (wenn der richtige Scheduler bereitgestellt wird), was zu nicht blockierenden Operationen führt. Ein schneller und unsauberer Test scheint jedoch zu ...
Retrofit / Rxjava und sitzungsbasierte Dienste
Ich implementiere sitzungsbasierte Dienste. Alle Anfragen müssen mit einem Cookie-Session-Parameter abonniert werden, der wiederum mit einer separaten Rest-API abgerufen wird. Der grundlegende Workflow besteht also darin, das Sitzungscookie ...
Warum wird mein Timer Observable nie aufgerufen?
uf Android habe ich ein @ geschriebObservable sollte nach 2000 ms einmal aufgerufen werden, wird aber nie aufgerufen. Observable.timer(2000, TimeUnit.MILLISECONDS) // wait 2000 ...
Wie warte ich mit RxJava-Android auf mehrere verschachtelte asynchrone Aufrufe?
Ich bin neu in RxJava, hier ist mein Fall, sende Anfrage A und erhalteList<A> zurücsende für jedes A die Anfrage AA und erhalte AA zurück, binde A und AA dannthere ist B & BB mit ähnlicher Logiktue etwas erst nachdem alle Anfragen abgeschlossen ...
as Sammeln von Observables in einer Liste scheint die Sammlung nicht sofort zu sende
Ich benutze RxJava, um im Wesentlichen die Liste der einzeln ausgegebenen Observables zu sammeln und zu einer Liste der Observables zu kombinieren (im Wesentlichen das Gegenteil von flatMap). Hier ist mein Code: // myEvent.findMemberships() ...
Observer.onError wird inkonsistent ausgelöst
Ich benutze Retrofit, um wie folgt auf meine API zuzugreifen: public interface UserService { ... @POST("/user/login") public Observable<User> register(@Body() User user); }So greife ich auf meine API zu: mUserService.register(user) ...
Asynchrone RestAPIs mit RxJava / Jersey2. Fragen zum Thema?
Wir sind dabei, ein REST-API mithilfe reaktiver Programmierung zu prototypisieren. Wie im Diagramm gezeigt, behalten wir 3 Ebenen bei, die wir in unseren vorherigen Sync-API-Designs verwendet habe http: //oi59.tinypic.com/339hhki.jp ...
RxJava: Unterschied zwischen doOnNext und doOnEach
In welchen Fällen sollte ich doOnNext verwenden und in welchen Fällen doOnEach? .doOnEach(new Action1<Notification<? super MessageProfile>>() { @Override public void call(Notification<? super MessageProfile> notification) { } }) .doOnNext(new ...