Uses of Interface
io.reactivex.rxjava3.operators.ConditionalSubscriber
-
-
Uses of ConditionalSubscriber in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement ConditionalSubscriber Modifier and Type Class Description (package private) static class
FlowableMapOptional.MapOptionalConditionalSubscriber<T,R>
(package private) static class
FlowableMapOptional.MapOptionalSubscriber<T,R>
(package private) static class
ParallelMapOptional.ParallelMapConditionalSubscriber<T,R>
(package private) static class
ParallelMapOptional.ParallelMapSubscriber<T,R>
(package private) static class
ParallelMapTryOptional.ParallelMapTryConditionalSubscriber<T,R>
(package private) static class
ParallelMapTryOptional.ParallelMapTrySubscriber<T,R>
Fields in io.reactivex.rxjava3.internal.jdk8 declared as ConditionalSubscriber Modifier and Type Field Description (package private) ConditionalSubscriber<? super T>
FlowableFromStream.StreamConditionalSubscription. downstream
(package private) ConditionalSubscriber<? super R>
ParallelMapOptional.ParallelMapConditionalSubscriber. downstream
(package private) ConditionalSubscriber<? super R>
ParallelMapTryOptional.ParallelMapTryConditionalSubscriber. downstream
Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type ConditionalSubscriber Constructor Description MapOptionalConditionalSubscriber(ConditionalSubscriber<? super R> downstream, Function<? super T,java.util.Optional<? extends R>> mapper)
ParallelMapConditionalSubscriber(ConditionalSubscriber<? super R> actual, Function<? super T,java.util.Optional<? extends R>> mapper)
ParallelMapTryConditionalSubscriber(ConditionalSubscriber<? super R> actual, Function<? super T,java.util.Optional<? extends R>> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
StreamConditionalSubscription(ConditionalSubscriber<? super T> downstream, java.util.Iterator<T> iterator, java.lang.AutoCloseable closeable)
-
Uses of ConditionalSubscriber in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as ConditionalSubscriber Modifier and Type Field Description (package private) ConditionalSubscriber<? super T>
FlowableDoFinally.DoFinallyConditionalSubscriber. downstream
(package private) ConditionalSubscriber<? super T>
FlowableFromArray.ArrayConditionalSubscription. downstream
(package private) ConditionalSubscriber<? super T>
FlowableFromIterable.IteratorConditionalSubscription. downstream
(package private) ConditionalSubscriber<? super T>
FlowableObserveOn.ObserveOnConditionalSubscriber. downstream
(package private) ConditionalSubscriber<? super java.lang.Integer>
FlowableRange.RangeConditionalSubscription. downstream
(package private) ConditionalSubscriber<? super java.lang.Long>
FlowableRangeLong.RangeConditionalSubscription. downstream
-
Uses of ConditionalSubscriber in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as ConditionalSubscriber Modifier and Type Field Description (package private) ConditionalSubscriber<? super T>
ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber. downstream
(package private) ConditionalSubscriber<? super T>
ParallelFilter.ParallelFilterConditionalSubscriber. downstream
(package private) ConditionalSubscriber<? super T>
ParallelFilterTry.ParallelFilterConditionalSubscriber. downstream
(package private) ConditionalSubscriber<? super R>
ParallelMap.ParallelMapConditionalSubscriber. downstream
(package private) ConditionalSubscriber<? super R>
ParallelMapTry.ParallelMapTryConditionalSubscriber. downstream
(package private) ConditionalSubscriber<? super T>
ParallelRunOn.RunOnConditionalSubscriber. downstream
-
Uses of ConditionalSubscriber in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement ConditionalSubscriber Modifier and Type Class Description class
BasicFuseableConditionalSubscriber<T,R>
Base class for a fuseable intermediate subscriber.Fields in io.reactivex.rxjava3.internal.subscribers declared as ConditionalSubscriber Modifier and Type Field Description protected ConditionalSubscriber<? super R>
BasicFuseableConditionalSubscriber. downstream
The downstream subscriber.Constructors in io.reactivex.rxjava3.internal.subscribers with parameters of type ConditionalSubscriber Constructor Description BasicFuseableConditionalSubscriber(ConditionalSubscriber<? super R> downstream)
Construct a BasicFuseableSubscriber by wrapping the given subscriber.
-