Suchergebnisse für Anfrage "rx-java"
IllegalArgumentException: Aufrufadapter für rx.Observable RxJava, Retrofit2 konnte nicht gefunden werden
Ich erhalte den obigen Fehler beim Aufrufen der restlichen API. Ich benutze sowohl retrofit2 als auch RxJava. ServiceFactory.javapublic class ServiceFactory { public static <T> T createRetrofitService(final Class<T> clazz, final String ...
Differenz zwischen CompletableFuture, Future und RxJava's Observable
Ich möchte den Unterschied zwischen @ wissCompletableFuture,Future undObservable RxJava. Was ich weiß ist, dass alle asynchron sind, aber Future.get() blockiert den Thread CompletableFuture gibt die Rückrufmethoden an RxJava Observable --- ...
Combine RxTextView Observable und Retrofit Observable
Als Beispiel für den Einstieg in RxAndroid versuche ich, ein Suchfeld zu implementieren, das einen Rest-Aufruf auslöst, wenn der Benutzer etwas einfügt. isher habe ich zwei Arbeitsteile. Die erste Beobachtung der EditTextView ...
Wie stoppen und fortsetzen Observable.interval emittiert Ticks
Dies gibt alle 5 Sekunden ein Häkchen aus. Observable.interval(5, TimeUnit.SECONDS, Schedulers.io()) .subscribe(tick -> Log.d(TAG, "tick = "+tick));Um es zu stoppen, können Sie @ verwend Schedulers.shutdown();Aber dann stoppen alle Scheduler ...
Observable wird im Hauptthread ausgeführt, obwohl subscribeOn () in einem anderen Thread aufgerufen wird.
Ich habe ein seltsames Problem bei einer meiner Aktivitäten. Wenn Sie von einem Foto / Video zurückkommen, können Sie in meinemonActivityResult Ich zeige ein Dialogfeld, in dem der Benutzer die Kamera benennen kann. Sobald der Benutzer OK drückt, ...
ReactiveX gibt nach Zeitüberschreitung einen Null- oder Sentinel-Wert aus
uf der Suche nach einem sauberen Weg, eine Quelle zu transformierObservable ein einzelnes @ ausgebnull (oder Sentinel-Wert), nachdem ein Element für einige Zeit nicht ausgegeben wurde. Zum Beispiel, wenn die beobachtbare Quelle @ ausgi1, 2, 3 ...
Wenn Sie ein Abonnement abbestellen möchten
Ich habe eine Frage zum Abbestellen einer Observable. Ich habe zwei Codes und bin mir nicht sicher, welcher besser ist. Beispiel 1 -> Abonnent abbestellen, sobald der Stream beendet ist: Subscriber<String> subscriber = new Subscriber<String>() ...
RxJava: Puffert Elemente, bis eine Bedingung für das aktuelle Element @ erfüllt is
Hier ist ein Ausschnitt, den ich herausfinden möchte: class RaceCondition { Subject<Integer, Integer> subject = PublishSubject.create(); public void entryPoint(Integer data) { subject.onNext(data); } public void client() { subject /*some ...
Wie kann ein Observable angehalten werden, ohne die ausgestrahlten Objekte zu verlieren?
Ich habe einObservable das jede Sekunde ein Häkchen abgibt: Observable.interval(0, 1, TimeUnit.SECONDS) .take(durationInSeconds + 1)); Ich möchte dieses Observable anhalten, damit es keine Zahlen mehr ausgibt, und es bei Bedarf fortsetzen. Es ...
Rx: Ein zip-ähnlicher Operator, der fortgesetzt wird, nachdem einer der Streams beendet wurde?
Ich möchte Streams (Observables) kombinieren, die asynchron beginnen und enden: -1----1----1----1---|-> -2----2--|-> [ optional_zip(sum) ] -1----3----3----1---|->Wofür ich es brauche: Hinzufügen von Audio-Streams zusammen. Es sind Streams von ...