OnSubscribeCombineLatest.java 文件源码

public SingleSourceProducer(final 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<T, R>(child, combinator);
}