agent/agent-framework
2
0
Fork 0
mirror of https://github.com/microsoft/agent-framework.git synced 2026-06-16 21:04:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: Update Concurrent sample to use message delivery event callback

Browse Source
This commit is contained in:
Jacob Alber
2026-04-03 17:44:13 -04:00
Unverified
parent 00adc5bf9e
commit 073114d2c1
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
dotnet/samples/03-workflows/Concurrent/Concurrent/Program.cs
+11 -9
View File
@@ -140,17 +140,19 @@ internal sealed partial class ConcurrentAggregationExecutor() :
public override async ValueTask HandleAsync(List<ChatMessage> message, IWorkflowContext context, CancellationToken cancellationToken = default)
{
this._messages.AddRange(message);
}
if (this._messages.Count == 2)
protected override ValueTask OnMessageDeliveryFinishedAsync(IWorkflowContext context, CancellationToken cancellationToken = default)
{
StringBuilder resultBuilder = new();
foreach (ChatMessage m in this._messages)
{
StringBuilder resultBuilder = new();
foreach (ChatMessage m in this._messages)
{
resultBuilder.AppendLine($"{m.AuthorName}: {m.Text}");
resultBuilder.AppendLine();
}
await context.YieldOutputAsync(resultBuilder.ToString(), cancellationToken);
resultBuilder.AppendLine($"{m.AuthorName}: {m.Text}");
resultBuilder.AppendLine();
}
this._messages.Clear();
return context.YieldOutputAsync(resultBuilder.ToString(), cancellationToken);
}
}