rx-kotlin2

0Hitze

2Antwort

Wie benutzt man RxJava2 combineLatest mit einer Liste von Observablen in Kotlin

Ich weiß, wie man das in RxJava 2 macht. Und ich weiß, wie RxKotlin hilft bei ähnlichen Problemen. Aber es scheint, dass RxKotlin.Observables nicht diese Hilfsfunktion für die Liste Überladung hat und

0Hitze

1Antwort

RxJava/RxKotlin Split-Stream je nach Subtyp

Ich habe einen Stream von ResponseMessage, die von verschiedenen Subtypen sein kann. Ich möchte den Stream in Streams aufteilen, wo ich jeden Typ in seinem eigenen Stream behandeln kann. Mein erster V

1Hitze

1Antwort

Kombinieren Sie zwei Subjekt nur, wenn man ändert und erhalten neueste von anderen

Im stecken bleiben bekommen das folgende Beispiel funktioniert wie erwartet, ich habe versucht mit zip und combineLatest und wie unten withLatestFrom jedoch keine von ihnen gibt die erwartete Ausgabe.

-1Hitze

1Antwort

RxJava2: onComplete nicht mit flatMapIterable

genannt Hier kurzen Code-Snippet wird: val subject = BehaviorSubject.createDefault(emptyList<Int>()) subject.onNext(Arrays.asList(1, 2, 3)) subject.flatMapIterable { list: List<Int> -> list

0Hitze

2Antwort

Chain Completable in Observable-Fluss

Angenommen, Sie möchten in Ihrer Observable-Kette eine Completable einfügen, z. B. für jedes emittierte Element, gibt es eine Compleable, die bis zum Abschluss ausgeführt und blockiert wird. Welche Op