Fix method name to message/stream

Change-Id: I5f0c9394d492abe61afa84d8ebb73b4f6dd34a1a

Author: kthota-g

examples/langgraph/agent_executor.py

@@ -53,7 +53,7 @@ async def on_message_stream(
         event_queue: EventQueue,
         task: Task | None,
     ) -> None:
-        """Handler for 'message/sendStream' requests."""
+        """Handler for 'message/stream' requests."""
         params: MessageSendParams = request.params
         query = self._get_user_query(params)
 

src/a2a/server/agent_execution/agent_executor.py

@@ -29,7 +29,7 @@ async def on_message_stream(
         event_queue: EventQueue,
         task: Task | None,
     ) -> None:
-        """Handler for 'message/sendStream' requests."""
+        """Handler for 'message/stream' requests."""
 
     @abstractmethod
     async def on_cancel(

src/a2a/server/agent_execution/base_agent_executor.py

@@ -29,7 +29,7 @@ async def on_message_stream(
         event_queue: EventQueue,
         task: Task | None,
     ) -> None:
-        """Handler for 'message/sendStream' requests."""
+        """Handler for 'message/stream' requests."""
         event_queue.enqueue_event(A2AError(UnsupportedOperationError()))
 
     async def on_cancel(

src/a2a/server/request_handlers/default_request_handler.py

@@ -141,7 +141,7 @@ async def on_message_send_stream(
         self,
         request: SendStreamingMessageRequest,
     ) -> AsyncGenerator[SendStreamingMessageResponse, None]:
-        """Default handler for 'message/sendStream'."""
+        """Default handler for 'message/stream'."""
         message_send_params: MessageSendParams = request.params
 
         task_manager = TaskManager(

src/a2a/types.py

@@ -1050,7 +1050,7 @@ class SendMessageRequest(BaseModel):
 
 class SendStreamingMessageRequest(BaseModel):
     """
-    JSON-RPC request model for the 'message/sendStream' method.
+    JSON-RPC request model for the 'message/stream' method.
     """
 
     id: str | int | None = None
@@ -1062,7 +1062,7 @@ class SendStreamingMessageRequest(BaseModel):
     """
     Specifies the version of the JSON-RPC protocol. MUST be exactly "2.0".
     """
-    method: Literal['message/sendStream'] = 'message/sendStream'
+    method: Literal['message/stream'] = 'message/stream'
     """
     A String containing the name of the method to be invoked.
     """
@@ -1278,7 +1278,7 @@ class SendMessageSuccessResponse(BaseModel):
 
 class SendStreamingMessageSuccessResponse(BaseModel):
     """
-    JSON-RPC success response model for the 'message/sendStream' method.
+    JSON-RPC success response model for the 'message/stream' method.
     """
 
     id: str | int | None = None
@@ -1347,5 +1347,5 @@ class SendStreamingMessageResponse(
 ):
     root: JSONRPCErrorResponse | SendStreamingMessageSuccessResponse
     """
-    JSON-RPC response model for the 'message/sendStream' method.
+    JSON-RPC response model for the 'message/stream' method.
     """

tests/test_types.py

@@ -518,12 +518,12 @@ def test_send_subscribe_request() -> None:
     params = MessageSendParams(message=Message(**MINIMAL_MESSAGE_USER))
     req_data: dict[str, Any] = {
         'jsonrpc': '2.0',
-        'method': 'message/sendStream',
+        'method': 'message/stream',
         'params': params.model_dump(),
         'id': 5,
     }
     req = SendStreamingMessageRequest.model_validate(req_data)
-    assert req.method == 'message/sendStream'
+    assert req.method == 'message/stream'
     assert isinstance(req.params, MessageSendParams)
     assert req.params.message.role == Role.user
 
@@ -874,13 +874,13 @@ def test_a2a_request_root_model() -> None:
     # SendStreamingMessageRequest case
     send_subs_req_data: dict[str, Any] = {
         'jsonrpc': '2.0',
-        'method': 'message/sendStream',
+        'method': 'message/stream',
         'params': send_params.model_dump(),
         'id': 1,
     }
     a2a_req_send_subs = A2ARequest.model_validate(send_subs_req_data)
     assert isinstance(a2a_req_send_subs.root, SendStreamingMessageRequest)
-    assert a2a_req_send_subs.root.method == 'message/sendStream'
+    assert a2a_req_send_subs.root.method == 'message/stream'
 
     # GetTaskRequest case
     get_params = TaskQueryParams(id='t2')