Top Description Fields Constructors Methods

io.reactivex.parallel

public final Enum ParallelFailureHandling

Class Inheritance

extends Enum<ParallelFailureHandling>
implements BiFunction<Long, Throwable, ParallelFailureHandling>

java.lang.Object
java.lang.Enum
io.reactivex.parallel.ParallelFailureHandling

All Implemented Interfaces

io.reactivex.functions.BiFunction

Imports

io.reactivex.functions.BiFunction

Enumerations for handling failure within a parallel operator.

History: 2.0.8 - experimental

Since: 2.2

Field Summary

Modifier and Type	Field and Description
public static final ParallelFailureHandling	ERROR The current rail is stopped and the error is signalled.
public static final ParallelFailureHandling	RETRY Retry the current value.
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.

Constructor Summary

Access	Constructor and Description
private	ParallelFailureHandling()

Method Summary

Modifier and Type	Method and Description
public ParallelFailureHandling	apply(Long the first value t1, Throwable the second value t2) Implements io.reactivex.functions.BiFunction.apply. Calculate a value based on the input values.
public static ParallelFailureHandling	valueOf(String name)
public static ParallelFailureHandling[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

ERROR	back to summary
public static final ParallelFailureHandling ERROR The current rail is stopped and the error is signalled.

RETRY	back to summary
public static final ParallelFailureHandling RETRY Retry the current value.

SKIP	back to summary
public static final ParallelFailureHandling SKIP The current value and error is ignored and the rail resumes with the next item.

STOP	back to summary
public static final ParallelFailureHandling STOP The current rail is stopped and the error is dropped.

Constructor Detail

ParallelFailureHandling	back to summary
private ParallelFailureHandling()

Method Detail

apply

back to summary

public ParallelFailureHandling apply(Long t1, Throwable t2)

Implements io.reactivex.functions.BiFunction.apply.

Doc from io.reactivex.functions.BiFunction.apply.

Calculate a value based on the input values.

Parameters

t1:Long: the first value
t2:Throwable: the second value

Returns:ParallelFailureHandling

the result value

Annotations

@Override

valueOf	back to summary
public static ParallelFailureHandling valueOf(String name)

values	back to summary
public static ParallelFailureHandling[] values()