Uses of Interface
io.reactivex.rxjava3.operators.ConditionalSubscriber
Packages that use ConditionalSubscriber
Package
Description
-
Uses of ConditionalSubscriber in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement ConditionalSubscriberModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.jdk8 declared as ConditionalSubscriberModifier and TypeFieldDescription(package private) final ConditionalSubscriber
<? super T> FlowableFromStream.StreamConditionalSubscription.downstream
(package private) final ConditionalSubscriber
<? super R> ParallelMapOptional.ParallelMapConditionalSubscriber.downstream
(package private) final ConditionalSubscriber
<? super R> ParallelMapTryOptional.ParallelMapTryConditionalSubscriber.downstream
Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type ConditionalSubscriberModifierConstructorDescription(package private)
MapOptionalConditionalSubscriber
(ConditionalSubscriber<? super R> downstream, Function<? super T, Optional<? extends R>> mapper) (package private)
ParallelMapConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, Optional<? extends R>> mapper) (package private)
ParallelMapTryConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, Optional<? extends R>> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
StreamConditionalSubscription
(ConditionalSubscriber<? super T> downstream, Iterator<T> iterator, AutoCloseable closeable) -
Uses of ConditionalSubscriber in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement ConditionalSubscriberModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as ConditionalSubscriberModifier and TypeFieldDescription(package private) final ConditionalSubscriber
<? super T> FlowableDoFinally.DoFinallyConditionalSubscriber.downstream
(package private) final ConditionalSubscriber
<? super T> FlowableFromArray.ArrayConditionalSubscription.downstream
(package private) final ConditionalSubscriber
<? super T> FlowableFromIterable.IteratorConditionalSubscription.downstream
(package private) final ConditionalSubscriber
<? super T> FlowableObserveOn.ObserveOnConditionalSubscriber.downstream
(package private) final ConditionalSubscriber
<? super Integer> FlowableRange.RangeConditionalSubscription.downstream
(package private) final ConditionalSubscriber
<? super Long> FlowableRangeLong.RangeConditionalSubscription.downstream
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type ConditionalSubscriberModifierConstructorDescription(package private)
ArrayConditionalSubscription
(ConditionalSubscriber<? super T> actual, T[] array) (package private)
DistinctUntilChangedConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Function<? super T, K> keySelector, BiPredicate<? super K, ? super K> comparer) (package private)
DoAfterConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Consumer<? super T> onAfterNext) (package private)
DoFinallyConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Action onFinally) (package private)
DoOnEachConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminate) (package private)
FilterConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Predicate<? super T> filter) (package private)
IteratorConditionalSubscription
(ConditionalSubscriber<? super T> actual, Iterator<? extends T> it) (package private)
MapConditionalSubscriber
(ConditionalSubscriber<? super U> actual, Function<? super T, ? extends U> function) (package private)
ObserveOnConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Scheduler.Worker worker, boolean delayError, int prefetch) (package private)
RangeConditionalSubscription
(ConditionalSubscriber<? super Integer> actual, int index, int end) (package private)
RangeConditionalSubscription
(ConditionalSubscriber<? super Long> actual, long index, long end) -
Uses of ConditionalSubscriber in io.reactivex.rxjava3.internal.operators.parallel
Classes in io.reactivex.rxjava3.internal.operators.parallel that implement ConditionalSubscriberModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as ConditionalSubscriberModifier and TypeFieldDescription(package private) final ConditionalSubscriber
<? super T> ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber.downstream
(package private) final ConditionalSubscriber
<? super T> ParallelFilter.ParallelFilterConditionalSubscriber.downstream
(package private) final ConditionalSubscriber
<? super T> ParallelFilterTry.ParallelFilterConditionalSubscriber.downstream
(package private) final ConditionalSubscriber
<? super R> ParallelMap.ParallelMapConditionalSubscriber.downstream
(package private) final ConditionalSubscriber
<? super R> ParallelMapTry.ParallelMapTryConditionalSubscriber.downstream
(package private) final ConditionalSubscriber
<? super T> ParallelRunOn.RunOnConditionalSubscriber.downstream
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type ConditionalSubscriberModifierConstructorDescription(package private)
ParallelDoOnNextConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelFilterConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate) (package private)
ParallelFilterConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelMapConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, ? extends R> mapper) (package private)
ParallelMapTryConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, ? extends R> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
RunOnConditionalSubscriber
(ConditionalSubscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker) -
Uses of ConditionalSubscriber in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement ConditionalSubscriberModifier and TypeClassDescriptionclass
Base class for a fuseable intermediate subscriber.Fields in io.reactivex.rxjava3.internal.subscribers declared as ConditionalSubscriberModifier and TypeFieldDescriptionprotected final ConditionalSubscriber
<? super R> BasicFuseableConditionalSubscriber.downstream
The downstream subscriber.Constructors in io.reactivex.rxjava3.internal.subscribers with parameters of type ConditionalSubscriberModifierConstructorDescriptionBasicFuseableConditionalSubscriber
(ConditionalSubscriber<? super R> downstream) Construct a BasicFuseableSubscriber by wrapping the given subscriber.