Skip to content

Commit bf04363

Browse files
committed
streaming chunk
1 parent c6fa543 commit bf04363

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/Extensions/AzureBlobPayloads/Interceptors/AzureBlobPayloadsInterceptor.cs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -245,6 +245,12 @@ async Task ResolveResponsePayloadsAsync<TResponse>(TResponse response, Cancellat
245245
await this.MaybeResolveAsync(v => s.Output = v, s.Output, cancellation);
246246
await this.MaybeResolveAsync(v => s.CustomStatus = v, s.CustomStatus, cancellation);
247247
break;
248+
case P.HistoryChunk c when c.Events != null:
249+
foreach (P.HistoryEvent e in c.Events)
250+
{
251+
await this.ResolveEventPayloadsAsync(e, cancellation);
252+
}
253+
break;
248254
case P.QueryInstancesResponse r:
249255
foreach (P.OrchestrationState s in r.OrchestrationState)
250256
{

0 commit comments

Comments
 (0)