Update client.py

grpclib/client.py

@@ -401,9 +401,9 @@ async def recv_message(self) -> Optional[_RecvType]:
 
         If server sends UNARY response, then you can call this coroutine only
         once. If server sends STREAM response, then you should call this
-        coroutine several times, until it returns None. To simplify you code in
-        this case, :py:class:`Stream` implements async iterations protocol, so
-        you can use it like this:
+        coroutine several times, until it returns None when the server has
+        ended the stream. To simplify you code in this case, :py:class:`Stream`
+        implements async iterations protocol, so you can use it like this:
 
         .. code-block:: python3
 
@@ -816,6 +816,7 @@ class ServiceMethod(Generic[_SendType, _RecvType]):
     """
     Base class for all gRPC method types
     """
+
     def __init__(
         self,
         channel: Channel,

grpclib/server.py

@@ -112,9 +112,10 @@ async def recv_message(self) -> Optional[_RecvType]:
 
         If client sends UNARY request, then you can call this coroutine
         only once. If client sends STREAM request, then you should call this
-        coroutine several times, until it returns None. To simplify your code
-        in this case, :py:class:`Stream` class implements async iteration
-        protocol, so you can use it like this:
+        coroutine several times, until it returns None when the client has
+        ended the stream. To simplify your code in this case,
+        :py:class:`Stream` class implements async iteration protocol, so
+        you can use it like this:
 
         .. code-block:: python3