java类rx.subscriptions.SerialSubscription的实例源码

ParentSubscriber(Subscriber<? super T> child, SerialSubscription ssub, ProducerArbiter arbiter, Observable<? extends T> alternate) {
    this.child = child;
    this.ssub = ssub;
    this.arbiter = arbiter;
    this.alternate = alternate;
}

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

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

public SwitchIfEmptySubscriber(Subscriber<? super T> child, final SerialSubscription ssub) {
    this.child = child;
    this.ssub = ssub;
}