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