interceptAfterNode

fun <TFeature : Any> interceptAfterNode(feature: AIAgentFeature<*, TFeature>, featureImpl: TFeature, handle: suspend TFeature.(node: AIAgentNodeBase<*, *>, context: AIAgentContextBase, input: Any?, output: Any?) -> Unit)(source)

Intercepts node execution after it completes.

Parameters

handle

The handler that processes after-node events

Example:

pipeline.interceptAfterNode(MyFeature, myFeatureImpl) { node, context, input, output ->
logger.info("Node ${node.name} executed with input: $input and produced output: $output")
}