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}")
}
Content copied to clipboard