OperatorSwitchIfEmpty.java 文件源码

public Subscriber<? super T> call(Subscriber<? super T> child) {
    SerialSubscription ssub = new SerialSubscription();
    ProducerArbiter arbiter = new ProducerArbiter();
    ParentSubscriber<T> parent = new ParentSubscriber(child, ssub, arbiter, this.alternate);
    ssub.set(parent);
    child.add(ssub);
    child.setProducer(arbiter);
    return parent;
}