Kombinieren Unbekannte Anzahl von Observablen in RxJava

Question

Ich habe eine Situation, wo ich N Observables basierend auf der Anfrage erstellen muss. Ich verstehe, dass ich zip verwenden kann, um bekannte Anzahl von Observablen zu kombinieren. Aber ich bin dabei zu verstehen, wie ich eine unbekannte Anzahl von Observablen kombinieren kann.

Der Teil, wo ich nicht klar bin, ist die Funktion zu zippen. Abhängig von der Anzahl der Observablen muss ich ein Lambda erstellen, das N Argumente akzeptiert.

Alle Observables geben verschiedene Arten von Objekten zurück.

Answer 1

Sie können Ihre Observable zurückgeben Objekte allgemeinste Art, fusionieren und zu verarbeiten als Liste machen:

class Result1 implements Result 
class Result2 implements Result 
class REsult3 implements Result 

for(Observable o : yourObservableList) 
    resultObservable.mergeWith(o) //use concat() if you need serial execution 

resultObservable 
    .toList() 
    .doOnNext(results -> { 
     //process your results (List<Result>) 
    } 
    .subscribe(...)