RxJava：动态创建 Observables 并将最终结果作为 Observable 发送

Question

我正在使用 RxJava，我想在其中根据某些条件动态创建许多 Observable。创建完成后，我想对可观察对象返回的不同值进行一些处理，然后作为可以订阅的单个可观察对象发送。这是我的代码：

List<String> valueList = .... 

List<Observable<String>> listOfObservables = new ArrayList<Observable<String>>();

for(int i =; i <valueList.size(); i++){
        listOfObservables.add(new SomeClass.doOperation(valueList(i)));
        // SomeClass.doOperation will return an Observable<String>
    }

return Observable.merge(listOfObservables);

但是在这里，我想对listOfObservable中不同Observables发出的值进行一些操作，最后将其作为单个Observable<String>返回

就像Observable.zip() 一样，我可以这样做

return Observable.zip(observable1, observable2, (string1, string2) -> {
            // joining final string here
            return string1 + string2;

但我知道这里的参数数量。请告诉我如何实现这一目标。

Answer 1

使用zip重载that takes a variable number of arguments，它有一个签名

<R> Observable<R> zip(Iterable<? extends Observable<?>> ws,
                      FuncN<? extends R> zipFunction)

示例用法：

List<String> valueList = .... 

return Observable.from(valueList)
    .map(string -> SomeClass.doOperationThatReturnsObservable(string))
    .toList()
    .flatMap(listOfObs -> Observable.zip(listOfObs, (Object[] results) -> {
       // do something with the strings in the array.
       return Arrays.stream(results)
                    .map(Object::toString)
                    .collect(Collectors.joining(","));
    }));