Uses of Enum Class
io.reactivex.rxjava3.parallel.ParallelFailureHandling
Packages that use ParallelFailureHandling
Package
Description
Contains the base type
ParallelFlowable
,
a sub-DSL for working with Flowable
sequences in parallel.-
Uses of ParallelFailureHandling in io.reactivex.rxjava3.internal.jdk8
Fields in io.reactivex.rxjava3.internal.jdk8 with type parameters of type ParallelFailureHandlingModifier and TypeFieldDescription(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTryOptional.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTryOptional.ParallelMapTryConditionalSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTryOptional.ParallelMapTrySubscriber.errorHandler
Constructor parameters in io.reactivex.rxjava3.internal.jdk8 with type arguments of type ParallelFailureHandlingModifierConstructorDescription(package private)
ParallelMapTryConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, Optional<? extends R>> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelMapTryOptional
(ParallelFlowable<T> source, Function<? super T, Optional<? extends R>> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelMapTrySubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, Optional<? extends R>> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) -
Uses of ParallelFailureHandling in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel with type parameters of type ParallelFailureHandlingModifier and TypeFieldDescription(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelDoOnNextTry.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelDoOnNextTry.ParallelDoOnNextSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelFilterTry.BaseFilterSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelFilterTry.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTry.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTry.ParallelMapTryConditionalSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTry.ParallelMapTrySubscriber.errorHandler
Constructor parameters in io.reactivex.rxjava3.internal.operators.parallel with type arguments of type ParallelFailureHandlingModifierConstructorDescription(package private)
BaseFilterSubscriber
(Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelDoOnNextConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelDoOnNextSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelDoOnNextTry
(ParallelFlowable<T> source, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelFilterConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelFilterSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelFilterTry
(ParallelFlowable<T> source, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelMapTry
(ParallelFlowable<T> source, Function<? super T, ? extends R> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelMapTryConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, ? extends R> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelMapTrySubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends R> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) -
Uses of ParallelFailureHandling in io.reactivex.rxjava3.parallel
Methods in io.reactivex.rxjava3.parallel that return ParallelFailureHandlingModifier and TypeMethodDescriptionstatic ParallelFailureHandling
Returns the enum constant of this class with the specified name.static ParallelFailureHandling[]
ParallelFailureHandling.values()
Returns an array containing the constants of this enum class, in the order they are declared.Methods in io.reactivex.rxjava3.parallel with parameters of type ParallelFailureHandlingModifier and TypeMethodDescriptionfinal @NonNull ParallelFlowable
<T> ParallelFlowable.doOnNext
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull ParallelFailureHandling errorHandler) Call the specified consumer with the current element passing through any 'rail' and handles errors based on the givenParallelFailureHandling
enumeration value.final @NonNull ParallelFlowable
<T> ParallelFlowable.filter
(@NonNull Predicate<? super @NonNull T> predicate, @NonNull ParallelFailureHandling errorHandler) Filters the source values on each 'rail' and handles errors based on the givenParallelFailureHandling
enumeration value.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.map
(@NonNull Function<? super @NonNull T, ? extends @NonNull R> mapper, @NonNull ParallelFailureHandling errorHandler) Maps the source values on each 'rail' to another value and handles errors based on the givenParallelFailureHandling
enumeration value.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper, @NonNull ParallelFailureHandling errorHandler) Maps the source values on each 'rail' to an optional and emits its value if any and handles errors based on the givenParallelFailureHandling
enumeration value.Method parameters in io.reactivex.rxjava3.parallel with type arguments of type ParallelFailureHandlingModifier and TypeMethodDescriptionfinal @NonNull ParallelFlowable
<T> ParallelFlowable.doOnNext
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Call the specified consumer with the current element passing through any 'rail' and handles errors based on the returned value by the handler function.final @NonNull ParallelFlowable
<T> ParallelFlowable.filter
(@NonNull Predicate<? super @NonNull T> predicate, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Filters the source values on each 'rail' and handles errors based on the returned value by the handler function.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.map
(@NonNull Function<? super @NonNull T, ? extends @NonNull R> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Maps the source values on each 'rail' to another value and handles errors based on the returned value by the handler function.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Maps the source values on each 'rail' to an optional and emits its value if any and handles errors based on the returned value by the handler function.