OnSubscribeCombineLatest.java 文件源码

public SingleSourceProducer(Subscriber<? super R> child, Observable<? extends T> source, FuncN<? extends R> combinator) {
    this.source = source;
    this.child = child;
    this.combinator = combinator;
    this.subscriber = new SingleSourceRequestableSubscriber(child, combinator);
}