OperatorRetryWithPredicate.java 文件源码

public SourceSubscriber(Subscriber<? super T> child, final BiFunction<Integer, Throwable, Boolean> predicate, Scheduler.Worker inner, 
        SerialSubscription serialSubscription) {
    this.child = child;
    this.predicate = predicate;
    this.inner = inner;
    this.serialSubscription = serialSubscription;
}