Uses of Class
io.reactivex.rxjava3.internal.util.ErrorMode
-
-
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.
-