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

Question

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 ich kann es nicht herausfinden. Wie würdest du das machen?

Answer 1

Die meisten statischen Funktionen in RxJava sind Erweiterungsfunktionen in RxKotlin. Diese spezielle Funktion ist eine Erweiterung auf . Sie können es so nennen:

listOfObservables.combineLatest { ... } 

Answer 2

val list = Arrays.asList(Observable.just(1), Observable.just("2")) 
Observable.combineLatest(list, object : FuncN<String>() { 
    fun call(vararg args: Any): String { 
     var concat = "" 
     for (value in args) { 
      if (value is Int) { 
       concat += value 
      } else if (value is String) { 
       concat += value 
      } 
     } 
     return concat 
    } 
}) 

Observable.just (1), Observable.just („2“) mit Liste der beobachtbaren und Anmeldung innerhalb Anruf Spaß geändert werden auch nach Bedarf ersetzt werden .