chore: Rename SendMessageStreamAsync method to SendMessageStreamingAsync (#127)

* Initial plan

* Rename SendMessageStreamAsync method to SendMessageStreamingAsync

Co-authored-by: brandonh-msft <20270743+brandonh-msft@users.noreply.github.com>

* Fix merge conflicts and compilation errors

- Resolved merge conflicts in TaskManagerTests.cs preserving both helper methods and renamed method
- Fixed nullable reference warnings in TaskManager.cs
- Updated all SendMessageStreamAsync calls to SendMessageStreamingAsync
- All 249 tests passing

Co-authored-by: adamsitnik <6011991+adamsitnik@users.noreply.github.com>

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: brandonh-msft <20270743+brandonh-msft@users.noreply.github.com>
Co-authored-by: Brandon H <brandonh-msft@users.noreply.github.com>
Co-authored-by: adamsitnik <6011991+adamsitnik@users.noreply.github.com>
Co-authored-by: Adam Sitnik <adam.sitnik@gmail.com>

Author: 3 people

samples/A2ACli/Host/A2ACli.cs

@@ -252,7 +252,7 @@ private static async Task<bool> CompleteTaskAsync(
         Console.WriteLine($"Send task payload => {JsonSerializer.Serialize(payload, jsonOptions)}");
         if (streaming)
         {
-            await foreach (var result in client.SendMessageStreamAsync(payload, cancellationToken))
+            await foreach (var result in client.SendMessageStreamingAsync(payload, cancellationToken))
             {
                 Console.WriteLine($"Stream event => {JsonSerializer.Serialize(result, jsonOptions)}");
             }

samples/AgentClient/Samples/MessageBasedCommunicationSample.cs

@@ -76,7 +76,7 @@ public static async Task RunAsync()
         await SendMessageAsync(agentClient, userMessage);
 
         // 5. Send the message using streaming API
-        await SendMessageStreamAsync(agentClient, userMessage);
+        await SendMessageStreamingAsync(agentClient, userMessage);
     }
 
     /// <summary>
@@ -100,13 +100,13 @@ private static async Task SendMessageAsync(A2AClient agentClient, Message userMe
     /// <param name="agentClient">The A2A client for communicating with the agent.</param>
     /// <param name="userMessage">The message to send to the agent.</param>
     /// <returns>A task representing the asynchronous operation.</returns>
-    private static async Task SendMessageStreamAsync(A2AClient agentClient, Message userMessage)
+    private static async Task SendMessageStreamingAsync(A2AClient agentClient, Message userMessage)
     {
         Console.WriteLine("\nStreaming Message Communication");
         Console.WriteLine($" Sending message via streaming API: {((TextPart)userMessage.Parts[0]).Text}");
 
         // Send the message and get the response as a stream
-        await foreach (SseItem<A2AEvent> sseItem in agentClient.SendMessageStreamAsync(new MessageSendParams { Message = userMessage }))
+        await foreach (SseItem<A2AEvent> sseItem in agentClient.SendMessageStreamingAsync(new MessageSendParams { Message = userMessage }))
         {
             Message agentResponse = (Message)sseItem.Data;
 

src/A2A.AspNetCore/A2AHttpProcessor.cs

@@ -129,7 +129,7 @@ internal static Task<IResult> SendMessageAsync(ITaskManager taskManager, ILogger
     internal static IResult SendMessageStream(ITaskManager taskManager, ILogger logger, MessageSendParams sendParams, CancellationToken cancellationToken)
         => WithExceptionHandling(logger, "SendMessageStream", () =>
         {
-            var taskEvents = taskManager.SendMessageStreamAsync(sendParams, cancellationToken);
+            var taskEvents = taskManager.SendMessageStreamingAsync(sendParams, cancellationToken);
 
             return new A2AEventStreamResult(taskEvents);
         }, sendParams.Message.TaskId);

src/A2A.AspNetCore/A2AJsonRpcProcessor.cs

@@ -184,7 +184,7 @@ internal static IResult StreamResponse(ITaskManager taskManager, string? request
                 return new JsonRpcStreamedResult(taskEvents, requestId);
             case A2AMethods.MessageStream:
                 var taskSendParams = DeserializeAndValidate<MessageSendParams>(parameters.Value);
-                var sendEvents = taskManager.SendMessageStreamAsync(taskSendParams, cancellationToken);
+                var sendEvents = taskManager.SendMessageStreamingAsync(taskSendParams, cancellationToken);
                 return new JsonRpcStreamedResult(sendEvents, requestId);
             default:
                 activity?.SetStatus(ActivityStatusCode.Error, "Invalid method");

src/A2A/Client/A2AClient.cs

@@ -77,7 +77,7 @@ public Task<TaskPushNotificationConfig> GetPushNotificationAsync(GetTaskPushNoti
             cancellationToken);
 
     /// <inheritdoc />
-    public IAsyncEnumerable<SseItem<A2AEvent>> SendMessageStreamAsync(MessageSendParams taskSendParams, CancellationToken cancellationToken = default) =>
+    public IAsyncEnumerable<SseItem<A2AEvent>> SendMessageStreamingAsync(MessageSendParams taskSendParams, CancellationToken cancellationToken = default) =>
         SendRpcSseRequestAsync(
             taskSendParams ?? throw new ArgumentNullException(nameof(taskSendParams)),
             A2AMethods.MessageStream,

src/A2A/Client/IA2AClient.cs

@@ -40,7 +40,7 @@ public interface IA2AClient
     /// <param name="taskSendParams">The message parameters containing the message and configuration.</param>
     /// <param name="cancellationToken">A cancellation token to cancel the operation.</param>
     /// <returns>An async enumerable of server-sent events containing Task, Message, TaskStatusUpdateEvent, or TaskArtifactUpdateEvent.</returns>
-    IAsyncEnumerable<SseItem<A2AEvent>> SendMessageStreamAsync(MessageSendParams taskSendParams, CancellationToken cancellationToken = default);
+    IAsyncEnumerable<SseItem<A2AEvent>> SendMessageStreamingAsync(MessageSendParams taskSendParams, CancellationToken cancellationToken = default);
 
     /// <summary>
     /// Subscribes to a task's event stream to receive ongoing updates.

src/A2A/Server/ITaskManager.cs

@@ -141,7 +141,7 @@ public interface ITaskManager
     /// <param name="messageSendParams">The message parameters containing the message content and optional task/context IDs.</param>
     /// <param name="cancellationToken">A cancellation token that can be used to cancel the operation.</param>
     /// <returns>An async enumerable that yields events as they are produced by the agent.</returns>
-    IAsyncEnumerable<A2AEvent> SendMessageStreamAsync(MessageSendParams messageSendParams, CancellationToken cancellationToken = default);
+    IAsyncEnumerable<A2AEvent> SendMessageStreamingAsync(MessageSendParams messageSendParams, CancellationToken cancellationToken = default);
 
     /// <summary>
     /// Resubscribes to an existing task's event stream to receive ongoing updates.

src/A2A/Server/TaskManager.cs

@@ -207,7 +207,7 @@ public async Task<AgentTask> CreateTaskAsync(string? contextId = null, string? t
     }
 
     /// <inheritdoc />
-    public async IAsyncEnumerable<A2AEvent> SendMessageStreamAsync(MessageSendParams messageSendParams, [EnumeratorCancellation] CancellationToken cancellationToken = default)
+    public async IAsyncEnumerable<A2AEvent> SendMessageStreamingAsync(MessageSendParams messageSendParams, [EnumeratorCancellation] CancellationToken cancellationToken = default)
     {
         cancellationToken.ThrowIfCancellationRequested();
 

tests/A2A.UnitTests/Client/A2AClientTests.cs

@@ -398,7 +398,7 @@ public async Task GetPushNotificationAsync_WithPushNotificationConfigId_MapsRequ
     }
 
     [Fact]
-    public async Task SendMessageStreamAsync_MapsRequestParamsCorrectly()
+    public async Task SendMessageStreamingAsync_MapsRequestParamsCorrectly()
     {
         // Arrange
         HttpRequestMessage? capturedRequest = null;
@@ -428,7 +428,7 @@ public async Task SendMessageStreamAsync_MapsRequestParamsCorrectly()
         };
 
         // Act
-        await foreach (var _ in sut.SendMessageStreamAsync(sendParams))
+        await foreach (var _ in sut.SendMessageStreamingAsync(sendParams))
         {
             break; // Only need to trigger the request
         }
@@ -459,7 +459,7 @@ public async Task SendMessageStreamAsync_MapsRequestParamsCorrectly()
     }
 
     [Fact]
-    public async Task SendMessageStreamAsync_MapsResponseCorrectly()
+    public async Task SendMessageStreamingAsync_MapsResponseCorrectly()
     {
         // Arrange
         var expectedMessage = new Message
@@ -483,7 +483,7 @@ public async Task SendMessageStreamAsync_MapsResponseCorrectly()
 
         // Act
         SseItem<A2AEvent>? result = null;
-        await foreach (var item in sut.SendMessageStreamAsync(sendParams))
+        await foreach (var item in sut.SendMessageStreamingAsync(sendParams))
         {
             result = item;
             break;
@@ -579,7 +579,7 @@ public async Task SubscribeToTaskAsync_MapsResponseCorrectly()
     }
 
     [Fact]
-    public async Task SendMessageStreamAsync_ThrowsOnJsonRpcError()
+    public async Task SendMessageStreamingAsync_ThrowsOnJsonRpcError()
     {
         // Arrange
         var sut = CreateA2AClient(JsonRpcResponse.InvalidParamsResponse("test-id"), isSse: true);
@@ -589,7 +589,7 @@ public async Task SendMessageStreamAsync_ThrowsOnJsonRpcError()
         // Act & Assert
         var exception = await Assert.ThrowsAsync<A2AException>(async () =>
         {
-            await foreach (var _ in sut.SendMessageStreamAsync(sendParams))
+            await foreach (var _ in sut.SendMessageStreamingAsync(sendParams))
             {
                 // Should throw before yielding any items
             }