refactor: simplify client factory interface and standardize streaming return types to StreamResponse

Author: guglielmo-san

src/a2a/client/base_client.py

@@ -64,7 +64,7 @@ async def send_message(
             context: Optional client call context.
 
         Yields:
-            An async iterator of `ClientEvent`
+            An async iterator of `StreamResponse`
         """
         self._apply_client_config(request)
         if not self._config.streaming or not self._card.capabilities.streaming:
@@ -314,7 +314,7 @@ async def subscribe(
             context: Optional client call context.
 
         Yields:
-            An async iterator of `ClientEvent` objects.
+            An async iterator of `StreamResponse` objects.
 
         Raises:
             NotImplementedError: If streaming is not supported by the client or server.
@@ -432,7 +432,7 @@ async def _execute_stream_with_interceptors(
         )
         before_result = await self._intercept_before(before_args)
 
-        if before_result:
+        if before_result is not None:
             after_args = AfterArgs(
                 result=before_result['early_return'],
                 method=method,

src/a2a/client/client.py

@@ -132,9 +132,7 @@ async def send_message(
 
         This will automatically use the streaming or non-streaming approach
         as supported by the server and the client config. Client will
-        aggregate update events and return an iterator of (`Task`,`Update`)
-        pairs, or a `Message`. Client will also send these values to any
-        configured `Consumer`s in the client.
+        aggregate update events and return an iterator of `StreamResponse`.
         """
         return
         yield

src/a2a/client/client_factory.py

@@ -63,12 +63,11 @@ class ClientFactory:
 
     .. code-block:: python
 
-        factory = ClientFactory(config, consumers)
+        factory = ClientFactory(config)
         # Optionally register custom client implementations
         factory.register('my_customer_transport', NewCustomTransportClient)
-        # Then with an agent card make a client with additional consumers and
-        # interceptors
-        client = factory.create(card, additional_consumers, interceptors)
+        # Then with an agent card make a client with additional interceptors
+        client = factory.create(card, interceptors)
 
     Now the client can be used consistently regardless of the transport. This
     aligns the client configuration with the server's capabilities.

tests/client/test_base_client.py

@@ -150,7 +150,6 @@ async def create_stream(*args, **kwargs):
         )
         assert not mock_transport.send_message.called
         assert len(events) == 1
-        # events[0] is (StreamResponse, Task) tuple
         response = events[0]
         assert response.task.id == 'task-123'