Uses of Interface
io.reactivex.rxjava3.operators.ConditionalSubscriber

Packages that use ConditionalSubscriber

Package	Description
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.parallel
io.reactivex.rxjava3.internal.subscribers

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

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement ConditionalSubscriber

Modifier and Type	Class	Description
(package private) static class	FlowableDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber<T,K>
(package private) static class	FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber<T,K>
(package private) static class	FlowableDoAfterNext.DoAfterConditionalSubscriber<T>
(package private) static class	FlowableDoFinally.DoFinallyConditionalSubscriber<T>
(package private) static class	FlowableDoOnEach.DoOnEachConditionalSubscriber<T>
(package private) static class	FlowableFilter.FilterConditionalSubscriber<T>
(package private) static class	FlowableFilter.FilterSubscriber<T>
(package private) static class	FlowableMap.MapConditionalSubscriber<T,U>
(package private) static class	FlowableSkipUntil.SkipUntilMainSubscriber<T>
(package private) static class	FlowableWithLatestFrom.WithLatestFromSubscriber<T,U,R>
(package private) static class	FlowableWithLatestFromMany.WithLatestFromSubscriber<T,R>

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

Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type ConditionalSubscriber

Constructor	Description
ArrayConditionalSubscription(ConditionalSubscriber<? super T> actual, T[] array)
DistinctUntilChangedConditionalSubscriber(ConditionalSubscriber<? super T> actual, Function<? super T,K> keySelector, BiPredicate<? super K,? super K> comparer)
DoAfterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Consumer<? super T> onAfterNext)
DoFinallyConditionalSubscriber(ConditionalSubscriber<? super T> actual, Action onFinally)
DoOnEachConditionalSubscriber(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, Consumer<? super java.lang.Throwable> onError, Action onComplete, Action onAfterTerminate)
FilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> filter)
IteratorConditionalSubscription(ConditionalSubscriber<? super T> actual, java.util.Iterator<? extends T> it)
MapConditionalSubscriber(ConditionalSubscriber<? super U> actual, Function<? super T,? extends U> function)
ObserveOnConditionalSubscriber(ConditionalSubscriber<? super T> actual, Scheduler.Worker worker, boolean delayError, int prefetch)
RangeConditionalSubscription(ConditionalSubscriber<? super java.lang.Integer> actual, int index, int end)
RangeConditionalSubscription(ConditionalSubscriber<? super java.lang.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 ConditionalSubscriber

Modifier and Type	Class	Description
(package private) static class	ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber<T>
(package private) static class	ParallelDoOnNextTry.ParallelDoOnNextSubscriber<T>
(package private) static class	ParallelFilter.BaseFilterSubscriber<T>
(package private) static class	ParallelFilter.ParallelFilterConditionalSubscriber<T>
(package private) static class	ParallelFilter.ParallelFilterSubscriber<T>
(package private) static class	ParallelFilterTry.BaseFilterSubscriber<T>
(package private) static class	ParallelFilterTry.ParallelFilterConditionalSubscriber<T>
(package private) static class	ParallelFilterTry.ParallelFilterSubscriber<T>
(package private) static class	ParallelMap.ParallelMapConditionalSubscriber<T,R>
(package private) static class	ParallelMapTry.ParallelMapTryConditionalSubscriber<T,R>
(package private) static class	ParallelMapTry.ParallelMapTrySubscriber<T,R>

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

Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type ConditionalSubscriber

Constructor	Description
ParallelDoOnNextConditionalSubscriber(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate)
ParallelFilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapConditionalSubscriber(ConditionalSubscriber<? super R> actual, Function<? super T,? extends R> mapper)
ParallelMapTryConditionalSubscriber(ConditionalSubscriber<? super R> actual, Function<? super T,? extends R> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
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 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.