OperatorSwitchIfEmpty.java 文件源码

@Override
public Subscriber<? super T> call(Subscriber<? super T> child) {
    final SerialSubscription ssub = new SerialSubscription();
    final SwitchIfEmptySubscriber parent = new SwitchIfEmptySubscriber(child, ssub);
    ssub.set(parent);
    child.add(ssub);
    return parent;
}