OperatorRetryWithPredicate.java 文件源码

@Override
public Subscriber<? super Observable<T>> call(final Subscriber<? super T> child) {
    final Scheduler.Worker inner = Schedulers.trampoline().createWorker();
    child.add(inner);

    final SerialSubscription serialSubscription = new SerialSubscription();
    // add serialSubscription so it gets unsubscribed if child is unsubscribed
    child.add(serialSubscription);

    return new SourceSubscriber<T>(child, predicate, inner, serialSubscription);
}