Stream chat messages from workflow

[Itay (itayfisz)]

I am migrating from SK, where I'm using AgentGroupChat.

AgentGroupChat group = ...;
await foreach (var message in group.InvokeAsync())
{
   // Here I have the message
}

I'm using instead a workflow, and I want to stream the ChatMessages. The WorkflowEvent provides only stream of tokens, but I want the full messages.

await using StreamingRun run = await InProcessExecution.StreamAsync(workflow, messages);
await run.TrySendMessageAsync(new TurnToken(emitEvents: true));

await foreach (WorkflowEvent evt in run.WatchStreamAsync())
{
   // <<< How do I get here the latest ChatMessage?
}

Any idea?

[Itay (itayfisz)]

I see this class could somewhat help, as it aggregates AgentRunResponseUpdate. But it's internal.

agent-framework/dotnet/src/Microsoft.Agents.AI.Hosting.OpenAI/Responses/AgentRunResponseUpdateExtensions.cs

Line 19 in feb3404

internal static class AgentRunResponseUpdateExtensions

I would really not want to do aggregations myself - it's not just aggregating textual tokens, for example I also need to aggregate token usage, etc...