IProgressSink
NexusLabs.Needlr.AgentFramework¶
NexusLabs.Needlr.AgentFramework.Progress¶
IProgressSink Interface¶
Receives progress events as they occur during agent/workflow execution. Consumers implement this to build SSE streams, console displays, trace diagrams, etc.
Methods¶
IProgressSink.OnEventAsync(IProgressEvent, CancellationToken) Method¶
Called for each progress event. Implementations should be fast — a slow sink
delays the agent pipeline (use ChannelProgressReporter for non-blocking delivery).
System.Threading.Tasks.ValueTask OnEventAsync(NexusLabs.Needlr.AgentFramework.Progress.IProgressEvent progressEvent, System.Threading.CancellationToken cancellationToken);
Parameters¶
progressEvent IProgressEvent
cancellationToken System.Threading.CancellationToken