public static interface Sinks.EmitFailureHandler
Sinks.Many.emitNext(Object, Sinks.EmitFailureHandler)), checking non-successful emission results from underlying
tryEmitAPI calls to decide whether or not such calls should be retried. Other than instructing to retry, the handlers are allowed to have side effects like parking the current thread for longer retry loops. They don't, however, influence the exact action taken by the emit API implementations when the handler doesn't allow the retry to occur.
|Modifier and Type||Field and Description|
A pre-made handler that will not instruct to retry any failure and trigger the failure handling immediately.
static final Sinks.EmitFailureHandler FAIL_FAST
boolean onEmitFailure(SignalType signalType, Sinks.EmitResult emitResult)
Sinks.EmitResultand the type of operation that was attempted (represented as a
SignalType). Side effects are allowed.