Class ParallelFilterTry.BaseFilterSubscriber<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.parallel.ParallelFilterTry.BaseFilterSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,ConditionalSubscriber<T>
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Direct Known Subclasses:
ParallelFilterTry.ParallelFilterConditionalSubscriber
,ParallelFilterTry.ParallelFilterSubscriber
- Enclosing class:
ParallelFilterTry<T>
abstract static class ParallelFilterTry.BaseFilterSubscriber<T>
extends Object
implements ConditionalSubscriber<T>, org.reactivestreams.Subscription
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> (package private) org.reactivestreams.Subscription
-
Constructor Summary
ConstructorsConstructorDescriptionBaseFilterSubscriber
(Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) -
Method Summary
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.reactivex.rxjava3.operators.ConditionalSubscriber
tryOnNext
Methods inherited from interface io.reactivex.rxjava3.core.FlowableSubscriber
onSubscribe
Methods inherited from interface org.reactivestreams.Subscriber
onComplete, onError
-
Field Details
-
predicate
-
errorHandler
-
upstream
org.reactivestreams.Subscription upstream -
done
boolean done
-
-
Constructor Details
-
BaseFilterSubscriber
BaseFilterSubscriber(Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
-
-
Method Details
-
request
public final void request(long n) - Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
cancel
public final void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
onNext
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<T>
-