before
Entry point for before.each(step) { … } on SagaBuilder.
Example:
sagaExecutor<Ctx, Result> {
first call "step" with { ctx -> process(ctx) }
before.each(step) { phase ->
if (!phase.context.authorized) halt because "not authorized"
}
}Content copied to clipboard