CtxDelayProvider
A delay provider executes the actual waiting period, in contrast to a CtxDelayStrategy, which only determines the delay duration. This provider can be used to implement custom delay logic with optional state between attempts. See DelayProvider for a context-agnostic version.
Stateless Example:
val statelessDelayProvider = CtxDelayProvider { attempt, context ->
val nextDuration = when {
attempt % 2 == 0 -> 1.seconds
else -> 2.seconds
}
// add additional logic with context
externalDelay(nextDuration) // your custom delay provider
Duration.ZERO // to skip the default delay provider
}Content copied to clipboard
Stateful Example:
val statefulDelayProvider = object : CtxDelayProvider<String> {
var delayProviderRetryCounter = 0
private set
override suspend fun delay(attempt: Int, context: String): Duration {
val nextDuration = when {
++delayProviderRetryCounter % 2 == 0 -> 1.seconds
else -> 2.seconds
}
// add additional logic with context
externalDelay(nextDuration) // your custom delay provider
return Duration.ZERO // to skip the default delay provider
}
}Content copied to clipboard
Note: A stateless custom delay provider that does not use an external delay will have the same behaviour as a CtxDelayStrategy. As such, it is recommended to use it instead.
By default, kotlinx.coroutines.delay is used as the delay provider.