diff --git a/Directory.Packages.props b/Directory.Packages.props index 4167b7ac..c270b4b3 100644 --- a/Directory.Packages.props +++ b/Directory.Packages.props @@ -6,7 +6,7 @@ - + diff --git a/src/A2A.AspNetCore/A2AHttpProcessor.cs b/src/A2A.AspNetCore/A2AHttpProcessor.cs index 34e16973..5074a785 100644 --- a/src/A2A.AspNetCore/A2AHttpProcessor.cs +++ b/src/A2A.AspNetCore/A2AHttpProcessor.cs @@ -289,8 +289,10 @@ public async Task ExecuteAsync(HttpContext httpContext) { await foreach (var taskEvent in _events.WithCancellation(httpContext.RequestAborted)) { + #pragma warning disable VSTHRD103 // Serialize to string is not blocking I/O var json = JsonSerializer.Serialize(taskEvent, A2AJsonUtilities.DefaultOptions.GetTypeInfo(typeof(StreamResponse))); + #pragma warning restore VSTHRD103 await httpContext.Response.BodyWriter.WriteAsync( Encoding.UTF8.GetBytes($"data: {json}\n\n"), httpContext.RequestAborted); await httpContext.Response.BodyWriter.FlushAsync(httpContext.RequestAborted); diff --git a/src/A2A.AspNetCore/JsonRpcStreamedResult.cs b/src/A2A.AspNetCore/JsonRpcStreamedResult.cs index a6a2bc71..49494b99 100644 --- a/src/A2A.AspNetCore/JsonRpcStreamedResult.cs +++ b/src/A2A.AspNetCore/JsonRpcStreamedResult.cs @@ -61,7 +61,9 @@ await SseFormatter.WriteAsync( ? JsonRpcResponse.CreateJsonRpcErrorResponse(_requestId, a2aEx) : JsonRpcResponse.InternalErrorResponse( _requestId, "An internal error occurred during streaming."); + #pragma warning disable VSTHRD103 // Serialize to string is not blocking I/O var errorJson = JsonSerializer.Serialize(errorResponse, responseTypeInfo); + #pragma warning restore VSTHRD103 var errorBytes = Encoding.UTF8.GetBytes($"data: {errorJson}\n\n"); await httpContext.Response.Body.WriteAsync(errorBytes, httpContext.RequestAborted); await httpContext.Response.Body.FlushAsync(httpContext.RequestAborted);