Class OperatorRetryWithPredicate.SourceSubscriber<T>