reactor.util.repeat

Interface RepeatSpec.RepeatSignal

Enclosing class:

RepeatSpec

public static interface RepeatSpec.RepeatSignal

State information associated with each repeat signal, used in repeat strategies.

Method Summary

Modifier and Type	Method and Description
java.time.Duration	backoff() Returns the delay before the next repeat attempt.
java.lang.Long	companionValue() Returns the value from the companion publisher that triggered this repeat signal.
RepeatSpec.RepeatSignal	copy() Returns an immutable copy of this RepeatSpec.RepeatSignal, capturing the current state.
long	iteration() Returns the current iteration count, starting from 0.
ContextView	repeatContextView() Returns the read-only context associated with this repeat signal.

Method Detail

iteration

long iteration()

Returns the current iteration count, starting from 0.

Returns:

the iteration index

companionValue

java.lang.Long companionValue()

Returns the value from the companion publisher that triggered this repeat signal.

Returns:

the companion value

backoff

java.time.Duration backoff()

Returns the delay before the next repeat attempt.

Returns:

the backoff duration

repeatContextView

ContextView repeatContextView()

Returns the read-only context associated with this repeat signal.

Returns:

the repeat context view

copy

RepeatSpec.RepeatSignal copy()

Returns an immutable copy of this RepeatSpec.RepeatSignal, capturing the current state.

Returns:

an immutable copy of the signal