OnSubscribeCombineLatest.java 文件源码

@SuppressWarnings("unchecked")
public MultiSourceProducer(final Subscriber<? super R> child, final 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);
}