我有一个可变长度的 Observable 数组。我想压缩请求(即发出一堆 API 请求并等待所有请求完成)，但我不知道如何实现压缩功能。
Observable.zip(observables, new FuncN<List<ResponseBody>>() {
@Override
public List<ResponseBody> call(Object... args) {
return Arrays.asList(args); <- compile error here
}
});
这里是 obserables是 List<Observable<ResponseBody>> 的数组并且它的长度是先验未知的。
调用zip函数的参数无法修正为ResponseBody... .如何让它返回 Observable<List<ResponseBody>> ？
是FuncN的设计约束吗？ RxJava 1.x.x?
附言我正在使用 RxJava 1.1.6。
最佳答案
只是merge您的可观察对象并使用 toList 收集结果:
Observable.merge(observables).toList()
关于rx-java - RxJava 对可变长度的 Retrofit Observable 数组进行 zip 操作，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/42412444/