Package com.couchbase.client.core.retry.reactor

Class DefaultContext<T>

java.lang.Object

com.couchbase.client.core.retry.reactor.DefaultContext<T>

All Implemented Interfaces:

IterationContext<T>, RepeatContext<T>, RetryContext<T>

public class DefaultContext<T>
extends Object
implements RetryContext<T>, RepeatContext<T>

Constructor Summary

Constructors

Constructor	Description
DefaultContext(T applicationContext, long iteration, BackoffDelay backoff, long repeatCompanionValue)
DefaultContext(T applicationContext, long iteration, BackoffDelay backoff, Throwable exception)

Method Summary

Modifier and Type	Method	Description
T	applicationContext()	Application context that may be used to perform any rollbacks before a retry.
Duration	backoff()	The backoff delay.
Long	companionValue()	Returns the value provided in the companion Flux for repeats.
Throwable	exception()	Returns the exception from the last iteration.
long	iteration()	The next iteration number.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DefaultContext

public DefaultContext(T applicationContext,
 long iteration,
 BackoffDelay backoff,
 long repeatCompanionValue)

DefaultContext

public DefaultContext(T applicationContext,
 long iteration,
 BackoffDelay backoff,
 Throwable exception)

Method Details

applicationContext

public T applicationContext()

Description copied from interface: IterationContext

Application context that may be used to perform any rollbacks before a retry. Application context can be configured using Retry.withApplicationContext(Object) or Repeat.withApplicationContext(Object).

Specified by:

applicationContext in interface IterationContext<T>

Returns:

application context

iteration

public long iteration()

Description copied from interface: IterationContext

The next iteration number. This is a zero-based incrementing number with the first attempt prior to any retries as iteration zero.

Specified by:

iteration in interface IterationContext<T>

Returns:

the current iteration number

companionValue

public Long companionValue()

Description copied from interface: RepeatContext

Returns the value provided in the companion Flux for repeats.

• For Flux.repeatWhen(java.util.function.Function) and Mono.repeatWhen(java.util.function.Function), value is the number of items emitted in the last attempt.
• For Mono.repeatWhenEmpty(java.util.function.Function) and Mono.repeatWhenEmpty(int, java.util.function.Function), value is a zero-based incrementing Long, which is number of attempts - 1.

Specified by:

companionValue in interface RepeatContext<T>

Returns:

value the value emitted on the companion Flux for repeats.

exception

public Throwable exception()

Description copied from interface: RetryContext

Returns the exception from the last iteration.

Specified by:

exception in interface RetryContext<T>

Returns:

exception that resulted in retry

backoff

public Duration backoff()

Description copied from interface: IterationContext

The backoff delay. When Backoff function is invoked, the previous backoff is provided in the context. The context provided for the retry predicates Retry.onlyIf(java.util.function.Predicate) and Repeat.onlyIf(java.util.function.Predicate) as well as the retry callbacks Retry.doOnRetry(java.util.function.Consumer) and Repeat.doOnRepeat(java.util.function.Consumer) provide the backoff delay for the next retry.

Specified by:

backoff in interface IterationContext<T>

Returns:

Backoff delay

toString

public String toString()

Overrides:

toString in class Object