CompletableOnSubscribeConcat.java 文件源码

public CompletableConcatSubscriber(CompletableSubscriber actual, int prefetch) {
    this.actual = actual;
    this.prefetch = prefetch;
    this.queue = new SpscArrayQueue<Completable>(prefetch);
    this.sr = new SerialSubscription();
    this.inner = new ConcatInnerSubscriber();
    this.wip = new AtomicInteger();
    add(sr);
    request(prefetch);
}