throw better error msg when stream is not opened

Author: chandra-siri

google/api_core/bidi.py

@@ -303,7 +303,7 @@ def send(self, request):
             request (protobuf.Message): The request to send.
         """
         if self.call is None:
-            raise ValueError("Cannot send on an RPC that has never been opened.")
+            raise ValueError("Cannot send on an RPC stream that has never been opened.")
 
         # Don't use self.is_active(), as ResumableBidiRpc will overload it
         # to mean something semantically different.
@@ -324,7 +324,7 @@ def recv(self):
             protobuf.Message: The received message.
         """
         if self.call is None:
-            raise ValueError("Cannot recv on an RPC that has never been opened.")
+            raise ValueError("Cannot recv on an RPC stream that has never been opened.")
 
         return next(self.call)
 

google/api_core/bidi_async.py

@@ -29,7 +29,6 @@
 _LOGGER = logging.getLogger(__name__)
 
 
-
 class _AsyncRequestQueueGenerator:
     """_AsyncRequestQueueGenerator is a helper class for sending asynchronous
       requests to a gRPC stream from a Queue.
@@ -218,7 +217,7 @@ async def send(self, request: ProtobufMessage) -> None:
             request (ProtobufMessage): The request to send.
         """
         if self.call is None:
-            raise ValueError("Cannot send on an RPC that has never been opened.")
+            raise ValueError("Cannot send on an RPC stream that has never been opened.")
 
         if not self.call.done():
             await self._request_queue.put(request)
@@ -235,7 +234,7 @@ async def recv(self) -> ProtobufMessage:
             ProtobufMessage: The received message.
         """
         if self.call is None:
-            raise ValueError("Cannot recv on an RPC that has never been opened.")
+            raise ValueError("Cannot recv on an RPC stream that has never been opened.")
 
         return await self.call.read()