interceptAfterNode

fun <TFeature : Any> interceptAfterNode(interceptContext: InterceptContext<TFeature>, handle: suspend TFeature.(eventContext: NodeAfterExecuteContext) -> Unit)(source)

Intercepts node execution after it completes.

Parameters

handle

The handler that processes after-node events

Example:

pipeline.interceptAfterNode(InterceptContext) { eventContext ->
logger.info("Node ${eventContext.node.name} executed with input: ${eventContext.input} and produced output: ${eventContext.output}")
}