Uses of Class
io.reactivex.rxjava3.parallel.ParallelFailureHandling
-
Packages that use ParallelFailureHandling Package Description io.reactivex.rxjava3.internal.jdk8 io.reactivex.rxjava3.internal.operators.parallel io.reactivex.rxjava3.parallel Contains the base typeParallelFlowable
, a sub-DSL for working withFlowable
sequences in parallel. -
-
Uses of ParallelFailureHandling in io.reactivex.rxjava3.internal.jdk8
Fields in io.reactivex.rxjava3.internal.jdk8 with type parameters of type ParallelFailureHandling Modifier and Type Field Description (package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelMapTryOptional. errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelMapTryOptional.ParallelMapTryConditionalSubscriber. errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelMapTryOptional.ParallelMapTrySubscriber. errorHandler
Constructor parameters in io.reactivex.rxjava3.internal.jdk8 with type arguments of type ParallelFailureHandling Constructor Description 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)
ParallelMapTryOptional(ParallelFlowable<T> source, Function<? super T,java.util.Optional<? extends R>> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapTrySubscriber(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,java.util.Optional<? extends R>> mapper, BiFunction<? super java.lang.Long,? super java.lang.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 ParallelFailureHandling Modifier and Type Field Description (package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelDoOnNextTry. errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber. errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelDoOnNextTry.ParallelDoOnNextSubscriber. errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelFilterTry.BaseFilterSubscriber. errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelFilterTry. errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelMapTry. errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelMapTry.ParallelMapTryConditionalSubscriber. errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>
ParallelMapTry.ParallelMapTrySubscriber. errorHandler
Constructor parameters in io.reactivex.rxjava3.internal.operators.parallel with type arguments of type ParallelFailureHandling Constructor Description BaseFilterSubscriber(Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelDoOnNextConditionalSubscriber(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelDoOnNextSubscriber(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelDoOnNextTry(ParallelFlowable<T> source, Consumer<? super T> onNext, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilterSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilterTry(ParallelFlowable<T> source, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapTry(ParallelFlowable<T> source, Function<? super T,? extends R> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapTryConditionalSubscriber(ConditionalSubscriber<? super R> actual, Function<? super T,? extends R> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapTrySubscriber(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,? extends R> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
-
Uses of ParallelFailureHandling in io.reactivex.rxjava3.parallel
Methods in io.reactivex.rxjava3.parallel that return ParallelFailureHandling Modifier and Type Method Description ParallelFailureHandling
ParallelFailureHandling. apply(java.lang.Long t1, java.lang.Throwable t2)
static ParallelFailureHandling
ParallelFailureHandling. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static ParallelFailureHandling[]
ParallelFailureHandling. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in io.reactivex.rxjava3.parallel with parameters of type ParallelFailureHandling Modifier and Type Method Description @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.@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.<@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.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.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 ParallelFailureHandling Modifier and Type Method Description @NonNull ParallelFlowable<T>
ParallelFlowable. doOnNext(@NonNull Consumer<? super @NonNull T> onNext, @NonNull BiFunction<? super java.lang.Long,? super java.lang.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.@NonNull ParallelFlowable<T>
ParallelFlowable. filter(@NonNull Predicate<? super @NonNull T> predicate, @NonNull BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
Filters the source values on each 'rail' and handles errors based on the returned value by the handler function.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. map(@NonNull Function<? super @NonNull T,? extends @NonNull R> mapper, @NonNull BiFunction<? super java.lang.Long,? super java.lang.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.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.Optional<? extends @NonNull R>> mapper, @NonNull BiFunction<? super java.lang.Long,? super java.lang.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.
-