Uses of Class
io.reactivex.rxjava3.internal.util.ErrorMode

Packages that use ErrorMode

Package	Description
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.mixed
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.parallel
io.reactivex.rxjava3.internal.util

Uses of ErrorMode in io.reactivex.rxjava3.internal.operators.flowable

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as ErrorMode

Modifier and Type	Field	Description
(package private) ErrorMode	FlowableConcatMap.errorMode
(package private) ErrorMode	FlowableConcatMapEager.ConcatMapEagerDelayErrorSubscriber.errorMode
(package private) ErrorMode	FlowableConcatMapEager.errorMode
(package private) ErrorMode	FlowableConcatMapEagerPublisher.errorMode
(package private) ErrorMode	FlowableConcatMapScheduler.errorMode

Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type ErrorMode

Modifier and Type	Method	Description
static <T,R> org.reactivestreams.Subscriber<T>	FlowableConcatMap.subscribe(org.reactivestreams.Subscriber<? super R> s, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode)

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

Constructor	Description
ConcatMapEagerDelayErrorSubscriber(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int maxConcurrency, int prefetch, ErrorMode errorMode)
FlowableConcatMap(Flowable<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode)
FlowableConcatMapEager(Flowable<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int maxConcurrency, int prefetch, ErrorMode errorMode)
FlowableConcatMapEagerPublisher(org.reactivestreams.Publisher<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int maxConcurrency, int prefetch, ErrorMode errorMode)
FlowableConcatMapScheduler(Flowable<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode, Scheduler scheduler)

Uses of ErrorMode in io.reactivex.rxjava3.internal.operators.mixed

Fields in io.reactivex.rxjava3.internal.operators.mixed declared as ErrorMode

Modifier and Type	Field	Description
(package private) ErrorMode	ConcatMapXMainObserver.errorMode
(package private) ErrorMode	ConcatMapXMainSubscriber.errorMode
(package private) ErrorMode	FlowableConcatMapCompletable.errorMode
(package private) ErrorMode	FlowableConcatMapMaybe.errorMode
(package private) ErrorMode	FlowableConcatMapMaybePublisher.errorMode
(package private) ErrorMode	FlowableConcatMapSingle.errorMode
(package private) ErrorMode	FlowableConcatMapSinglePublisher.errorMode
(package private) ErrorMode	ObservableConcatMapCompletable.errorMode
(package private) ErrorMode	ObservableConcatMapMaybe.errorMode
(package private) ErrorMode	ObservableConcatMapSingle.errorMode

Constructors in io.reactivex.rxjava3.internal.operators.mixed with parameters of type ErrorMode

Constructor	Description
ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
ConcatMapMaybeMainObserver(Observer<? super R> downstream, Function<? super T,? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)
ConcatMapMaybeSubscriber(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T,? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)
ConcatMapSingleMainObserver(Observer<? super R> downstream, Function<? super T,? extends SingleSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)
ConcatMapSingleSubscriber(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T,? extends SingleSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)
ConcatMapXMainObserver(int prefetch, ErrorMode errorMode)
ConcatMapXMainSubscriber(int prefetch, ErrorMode errorMode)
FlowableConcatMapCompletable(Flowable<T> source, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
FlowableConcatMapMaybe(Flowable<T> source, Function<? super T,? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch)
FlowableConcatMapMaybePublisher(org.reactivestreams.Publisher<T> source, Function<? super T,? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch)
FlowableConcatMapSingle(Flowable<T> source, Function<? super T,? extends SingleSource<? extends R>> mapper, ErrorMode errorMode, int prefetch)
FlowableConcatMapSinglePublisher(org.reactivestreams.Publisher<T> source, Function<? super T,? extends SingleSource<? extends R>> mapper, ErrorMode errorMode, int prefetch)
ObservableConcatMapCompletable(Observable<T> source, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
ObservableConcatMapMaybe(Observable<T> source, Function<? super T,? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch)
ObservableConcatMapSingle(ObservableSource<T> source, Function<? super T,? extends SingleSource<? extends R>> mapper, ErrorMode errorMode, int prefetch)

Uses of ErrorMode in io.reactivex.rxjava3.internal.operators.observable

Fields in io.reactivex.rxjava3.internal.operators.observable declared as ErrorMode

Modifier and Type	Field	Description
(package private) ErrorMode	ObservableConcatMap.delayErrors
(package private) ErrorMode	ObservableConcatMapScheduler.delayErrors
(package private) ErrorMode	ObservableConcatMapEager.ConcatMapEagerMainObserver.errorMode
(package private) ErrorMode	ObservableConcatMapEager.errorMode

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type ErrorMode

Constructor	Description
ConcatMapEagerMainObserver(Observer<? super R> actual, Function<? super T,? extends ObservableSource<? extends R>> mapper, int maxConcurrency, int prefetch, ErrorMode errorMode)
ObservableConcatMap(ObservableSource<T> source, Function<? super T,? extends ObservableSource<? extends U>> mapper, int bufferSize, ErrorMode delayErrors)
ObservableConcatMapEager(ObservableSource<T> source, Function<? super T,? extends ObservableSource<? extends R>> mapper, ErrorMode errorMode, int maxConcurrency, int prefetch)
ObservableConcatMapScheduler(ObservableSource<T> source, Function<? super T,? extends ObservableSource<? extends U>> mapper, int bufferSize, ErrorMode delayErrors, Scheduler scheduler)

Uses of ErrorMode in io.reactivex.rxjava3.internal.operators.parallel

Fields in io.reactivex.rxjava3.internal.operators.parallel declared as ErrorMode

Modifier and Type	Field	Description
(package private) ErrorMode	ParallelConcatMap.errorMode

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

Constructor	Description
ParallelConcatMap(ParallelFlowable<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode)

Uses of ErrorMode in io.reactivex.rxjava3.internal.util

Methods in io.reactivex.rxjava3.internal.util that return ErrorMode

Modifier and Type	Method	Description
static ErrorMode	ErrorMode.valueOf(java.lang.String name)	Returns the enum constant of this type with the specified name.
static ErrorMode[]	ErrorMode.values()	Returns an array containing the constants of this enum type, in the order they are declared.