stepWithTimeout

fun <R> stepWithTimeout(name: String, timeout: Duration, action: suspend () -> R, compensation: suspend (R) -> Unit? = null): SagaBuilder<T>(source)

Adds a step with timeout.

Parameters

name

Human-readable name for the step

timeout

Maximum time allowed for the action

action

The action to execute

compensation

The compensation action to execute on failure (optional)