Package io.reactivex.rxjava3.parallel
Enum Class ParallelFailureHandling
- All Implemented Interfaces:
BiFunction<Long,
,Throwable, ParallelFailureHandling> Serializable
,Comparable<ParallelFailureHandling>
,Constable
public enum ParallelFailureHandling
extends Enum<ParallelFailureHandling>
implements BiFunction<Long,Throwable,ParallelFailureHandling>
Enumerations for handling failure within a parallel operator.
History: 2.0.8 - experimental
- Since:
- 2.2
-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Enum
Enum.EnumDesc<E extends Enum<E>>
-
Enum Constant Summary
Enum Constants -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionCalculate a value based on the input values.static ParallelFailureHandling
Returns the enum constant of this class with the specified name.static ParallelFailureHandling[]
values()
Returns an array containing the constants of this enum class, in the order they are declared.
-
Enum Constant Details
-
STOP
The current rail is stopped and the error is dropped. -
ERROR
The current rail is stopped and the error is signalled. -
SKIP
The current value and error is ignored and the rail resumes with the next item. -
RETRY
Retry the current value.
-
-
Constructor Details
-
ParallelFailureHandling
private ParallelFailureHandling()
-
-
Method Details
-
values
Returns an array containing the constants of this enum class, in the order they are declared.- Returns:
- an array containing the constants of this enum class, in the order they are declared
-
valueOf
Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)- Parameters:
name
- the name of the enum constant to be returned.- Returns:
- the enum constant with the specified name
- Throws:
IllegalArgumentException
- if this enum class has no constant with the specified nameNullPointerException
- if the argument is null
-
apply
Description copied from interface:BiFunction
Calculate a value based on the input values.- Specified by:
apply
in interfaceBiFunction<Long,
Throwable, ParallelFailureHandling> - Parameters:
t1
- the first valuet2
- the second value- Returns:
- the result value
-