OperatorZip.java 文件源码

public Zip(Subscriber<? super R> child, FuncN<? extends R> zipFunction) {
    this.child = child;
    this.zipFunction = zipFunction;
    child.add(this.childSubscription);
}