Observable.java 文件源码

public static final <R> Observable<R> zip(Iterable<? extends Observable<?>> ws, FuncN<? extends R> zipFunction) {
    List<Observable<?>> os = new ArrayList();
    for (Observable<?> o : ws) {
        os.add(o);
    }
    return just(os.toArray(new Observable[os.size()])).lift(new OperatorZip(zipFunction));
}