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 java.lang.Object implements ConditionalSubscriber<T>, org.reactivestreams.Subscription
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
done
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
errorHandler
(package private) Predicate<? super T>
predicate
(package private) org.reactivestreams.Subscription
upstream
-
Constructor Summary
Constructors Constructor Description BaseFilterSubscriber(Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
-
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
-
-
-
-
Field Detail
-
errorHandler
final BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler
-
upstream
org.reactivestreams.Subscription upstream
-
done
boolean done
-
-
Constructor Detail
-
BaseFilterSubscriber
BaseFilterSubscriber(Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
-
-