Class ParallelFilter.BaseFilterSubscriber<T>
- java.lang.Object
-
- io.reactivex.rxjava3.internal.operators.parallel.ParallelFilter.BaseFilterSubscriber<T>
-
- All Implemented Interfaces:
FlowableSubscriber<T>
,ConditionalSubscriber<T>
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Direct Known Subclasses:
ParallelFilter.ParallelFilterConditionalSubscriber
,ParallelFilter.ParallelFilterSubscriber
- Enclosing class:
- ParallelFilter<T>
abstract static class ParallelFilter.BaseFilterSubscriber<T> extends java.lang.Object implements ConditionalSubscriber<T>, org.reactivestreams.Subscription
-
-
Constructor Summary
Constructors Constructor Description BaseFilterSubscriber(Predicate<? super T> predicate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
void
onNext(T t)
void
request(long n)
-
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
-
-