RxJava - Zip-Liste von Observable

Question

Ich habe eine Liste von Observables (RxJava 1).

List<Observable> observableList = new ArrayList<>(); 

Es kann mindestens 1 Observable enthalten. Jeder hat den gleichen Typ des Ergebnisses.

Wie kann ich die Ergebnisse aller Observables zippen?

Ich dachte über zip-Betreiber aber keine Liste unterstützen, und ich weiß nicht Quantität von Observablen (es 1,2,3,4 sein kann ....)

Answer 1

Sie können die Verwendung statisch zip(java.lang.Iterable<? extends Observable<?>> ws,FuncN<? extends R> zipFunction) method.

Es wird ein zip Methode, die eine Iterable von Observable s und einen FuncN (das für seine call Methode nimmt einen varargs Parameter) hat und verwendet sie, um die entsprechenden emittierten Object s in das Ergebnis zu kombinieren, indem die neue weggelassen werden zurückgegeben Observable.

So zum Beispiel die Sie tun können:

Observable.zip(observableList, new FuncN(){ 
    public ReturnType call(java.lang.Object... args){ 
     ReturnType result; //to be made 
     //preparatory code for using the args 
     for (Object obj : args){ 
      ReturnType retObj = (ReturnType)obj; 
      //code to use the arg once at a time to combine N of them into one. 
     } 
     return result; 
    } 
});