OperatorZip.java 文件源码

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