rx-java

0Hitze

1Antwort

, wenn ich eine andere schduler subscribeon, gratis anmelden nicht mehr funktioniert

* Der folgende Code hat nichts drucken, mich verwirrt * wenn ich subscribeon entfernen, es funktioniert, drucken, was ich will Observable observable = Observable.<String>create(subscriber -> {

-1Hitze

1Antwort

Nachrüstung von 2 sequentiellen Anfragen mit asynchronen Netzwerkanrufen mit Wiederholung

Ich versuche, eine Netzwerkanforderung an eine API mit Retrofit zu senden, und wenn ich zurück Antwort, verwenden Sie einen Teil dieser Antwort in einem anderen Anruf, ich verwendete Anruf und RXJAVA

0Hitze

1Antwort

RxJava Haken nicht auf benutzerdefinierte Scheduler aufgerufen wird

Ich habe über RxJavaHooks.setOnScheduleAction(new MyOnScheduleAction()); einen Haken registriert und einen benutzerdefinierten Scheduler erstellt (zu Testzwecken) mit aber das folgende Stück Code do

0Hitze

2Antwort

Warum Intervall Operator in RxJava die Ergebnisse von flatMap ändern

ich diesen Code leite: private void concatenatedSets() { Observable<String> concatenatedSets = Observable.just("1/5/8", "1/9/11/58/16/", "9/15/56/49/21"); concatenatedSets.flatMap(s

0Hitze

1Antwort

Wie konvertiere ich dieses RxJava-Observable, um alle 200 ms Ergebnisse zu erhalten?

Ich habe diese Observable: Observable<String> concatenatedSets = Observable.just("1/5/8", "1/9/11/58/16/", "9/15/56/49/21"); concatenatedSets.flatMap(s -> Observable.from(s.split("/")))

0Hitze

2Antwort

Griff Retrofit Service-Antwort in RxJava Android App nach der Orientierung ändern

Ich habe einen Android-App, die einen Retrofit-Service-Aufruf uploadPhoto nach dem Button-Klick macht. In diesem Aufruf Antwortdienst Ich mag würde eine Foto-ID erhalten, damit ich an die Dienstantwor

0Hitze

1Antwort

Kombinieren Observablen in RxJava, gibt es einen besseren Weg, dies zu tun?

Ich lerne RxJava. Ich lade Filminformationen von zwei APIs ab. Das erste API (Api1 Klasse) empfängt ein id und gibt eine JSON (Api1Dto Klasse): { id : "123456", title : "Top Secret", api2Id : "7787" }

1Hitze

2Antwort

Wie bestellt man Ergebnisse von couchbase mit Bulk bekommt

Ich versuche, die Leistung der Abfrage einer Couchbase-Ansicht zu verbessern, indem Async verwendet wird. Ich habe ihre Dokumentation über die richtige Art und Weise zu lesen, dies zu tun, es geht so

1Hitze

1Antwort

RxView.debounce wartet auf den Zeitraum der Entprellung, um den Befehl auszuführen, wie führe ich den Befehl sofort aus?

Ich habe den folgenden Code in meinem Android-App, mehrere Klicks auf eine Schaltfläche zu verhindern versuchen: von RxView.clicks(bSubmit) .debounce(2500, TimeUnit.MILLISECONDS) .observ

0Hitze

2Antwort

Kettenmethoden auf rxjava

Wie man eine Methode aufruft, nachdem alle anderen Methoden verwirklicht worden sind. Alle Methoden haben Observable. Observable.just("" ) .subscribe(new Subscriber<String>() { @Over