CompletableOnSubscribeConcatArray.java 文件源码

public ConcatInnerSubscriber(CompletableSubscriber actual, Completable[] sources) {
    this.actual = actual;
    this.sources = sources;
    this.sd = new SerialSubscription();
}