OnSubscribeCombineLatest.java 文件源码

public OnSubscribeCombineLatest(List<? extends Observable<? extends T>> sources, FuncN<? extends R> combinator) {
    this.sources = sources;
    this.combinator = combinator;
    if (sources.size() > 128) {
        // For design simplicity this is limited to 128. If more are really needed we'll need to adjust 
        // the design of how RxRingBuffer is used in the implementation below.
        throw new IllegalArgumentException("More than 128 sources to combineLatest is not supported.");
    }
}