OperatorRetryWithPredicate.java 文件源码

public Subscriber<? super Observable<T>> call(Subscriber<? super T> child) {
    Worker inner = Schedulers.trampoline().createWorker();
    child.add(inner);
    SerialSubscription serialSubscription = new SerialSubscription();
    child.add(serialSubscription);
    ProducerArbiter pa = new ProducerArbiter();
    child.setProducer(pa);
    return new SourceSubscriber(child, this.predicate, inner, serialSubscription, pa);
}