reactivex

6Hitze

2Antwort

ReactiveX: Fehlerbehandlung, die das Observable nicht zerstört

Es ist nicht klar, wie Fehler an Abonnenten in REactiveX weitergeleitet werden, so dass das Observable nicht zerstört wird. Beispiel observable.onNext(1); observable.onNext(2); observable.onError("N

0Hitze

1Antwort

RxJava retryWhen und onError

Ich beginne zu entwickeln rxJava verwenden, und ich habe die folgende Situation: Ich habe einen beobachtbaren und ich möchte einen Teilnehmer haben den Fehler onError und andere Teilnehmer zu handhabe

0Hitze

1Antwort

RxJS vs rx-Knoten

Was ist der Unterschied zwischen RxJS und rx-node? Warum sollte ich nicht einfach RxJS anstelle von rx-node in meinem NodeJS-Projekt verwenden?

0Hitze

1Antwort

Wrapping Observablen in Aktion eines anderen beobachtbaren

ich auf ReactiveX und Retrofit gerade erst begonnen, Betrachtet folgendes Beispiel Beispiel Nachrüstung @GET public Observable<ResponseType1> makeFirstCall(); @POST public Observable<ResponseType2

0Hitze

3Antwort

Limit-Aktionen mit rxJava und retryWhen Betreiber

Meine Anwendung muss in der Regel zwei Dinge tun: nur eine Netzwerkanfrage zur gleichen Zeit Accept Retry wenn Anfrage fehlgeschlagen Das ist, wie ich Implementieren Sie es: public class RequestsLocke

1Hitze

1Antwort

RxSwift: Empfängt Ereignisse sofort, außer das letzte Ereignis wurde innerhalb eines bestimmten Intervalls verarbeitet

Neu bei RxSwift/Reactivex. Grundsätzlich versuche ich, einen Server anzurufen, wenn etwas passiert, aber stelle sicher, dass es nicht öfter als alle 10 Sekunden gemacht wird. Weniger oft wenn möglich.

2Hitze

2Antwort

Filter eine beobachtbare durch eine beobachtbare

Lassen Sie uns die folgende vereinfachte Situation berücksichtigen: Wir haben eine beobachtbare Äpfel vom Typ beobachtbare < Apfel> Jedes Apple-Objekt verfügt über eine Methode isRotten(), die gibt ei

0Hitze

2Antwort

Wie kann ich mehrere beobachtbare Aufrufe asynchron aufrufen, aber gleichzeitig vor und nach diesen Aufrufen einige Berechnungen durchführen?

Ich bin neu bei RxJava. Ich habe ein paar Jersey RxJava Kunden, die Observables zurückgeben. Ich muss einen Anruf tätigen, um einige Daten zu erhalten, diese Daten werden die Eingabe für meine nächste

4Hitze

4Antwort

Rx: Wie bekomme ich das letzte Element, selbst wenn onError aufgerufen wurde?

Ich verwende RxJava, und ich brauche 2 Dinge zu tun: das letzte Element aus dem Observable emittiert Holen Sie fest, ob onError, gegen onCompleted ich genannt wurde Ich habe mit last und lastOrDefault

1Hitze

1Antwort

SkipUntil funktioniert nicht wie erwartet

Ich suche den Operator SkipUntil, aber scheint wie funktioniert nicht so, wie ich es erwarte. Hier ist mein Code @Test public void testSkiUitil() throws InterruptedException { List<Integer> numb