public
final
enum
implements BiFunction<T1, T2, R>
ParallelFailureHandling
extends Enum<E extends Enum<E>>implements BiFunction<T1, T2, R>
| java.lang.Object | ||
| ↳ | java.lang.Enum<E extends java.lang.Enum<E>> | |
| ↳ | io.reactivex.parallel.ParallelFailureHandling | |
Class Overview
Enumerations for handling failure within a parallel operator.
Summary
| Enum Values | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
| ParallelFailureHandling | ERROR | The current rail is stopped and the error is signalled. | |||||||||
| ParallelFailureHandling | RETRY | Retry the current value. | |||||||||
| ParallelFailureHandling | SKIP | The current value and error is ignored and the rail resumes with the next item. | |||||||||
| ParallelFailureHandling | STOP | The current rail is stopped and the error is dropped. | |||||||||
| Public Methods | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
| ParallelFailureHandling | apply(Long t1, Throwable t2) | ||||||||||
| static ParallelFailureHandling | valueOf(String name) | ||||||||||
| final static ParallelFailureHandling[] | values() | ||||||||||
|
[Expand]
Inherited Methods | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
From class
java.lang.Enum
| |||||||||||
|
From class
java.lang.Object
| |||||||||||
|
From interface
io.reactivex.functions.BiFunction
| |||||||||||
|
From interface
java.lang.Comparable
| |||||||||||
Enum Values
public static final ParallelFailureHandling ERROR
The current rail is stopped and the error is signalled.
public static final ParallelFailureHandling SKIP
The current value and error is ignored and the rail resumes with the next item.
public static final ParallelFailureHandling STOP
The current rail is stopped and the error is dropped.