Объединение нескольких наблюдаемых в RxJava

Question

Допустим, что у меня есть 'N' источников данных (REST API, например):

Observable<List<DataItem>> source1 = api.source1(); 
Observable<List<DataItem>> source2 = api.source2(); 
Observable<List<DataItem>> source3 = api.source3(); 
... 
Observable<List<DataItem>> sourcen = api.sourcen(); 

где 'п' относительно мала (~ 10)

То, что я хочу сделать это, чтобы взять все эти источники, запустить их параллельно и получить List<DataItem> list, содержащий все DataItems из всех наблюдаемых, но только после завершения каждого сетевого вызова.

Заранее спасибо

Answer 1

Можно сделать что-то вроде:

List<Observable<?>> obsList = Arrays.asList(source1, source2, source3, ...); 

Observable.zip(obsList, ...