OnSubscribeCombineLatest.java 文件源码

public MultiSourceProducer(Subscriber<? super R> child, List<? extends Observable<? extends T>> sources, FuncN<? extends R> combinator) {
    this.sources = sources;
    this.child = child;
    this.combinator = combinator;
    int n = sources.size();
    this.subscribers = new MultiSourceRequestableSubscriber[n];
    this.collectedValues = new Object[n];
    this.haveValues = new BitSet(n);
    this.completion = new BitSet(n);
}