docs: correct invalid docstrings in _StreamMultiplexer

Author: zhixiangli

packages/google-cloud-storage/google/cloud/storage/asyncio/_stream_multiplexer.py

@@ -29,7 +29,7 @@
 
 
 class _StreamError:
-    """Wraps a retryable error with the stream generation that produced it."""
+    """Wraps an error with the stream generation that produced it."""
 
     def __init__(self, exception: Exception, generation: int):
         self.exception = exception
@@ -77,7 +77,7 @@ def register(self, read_ids: Set[int]) -> asyncio.Queue:
         return queue
 
     def unregister(self, read_ids: Set[int]) -> None:
-        """Remove read_ids from routing. Stops recv loop if no tasks remain."""
+        """Remove read_ids from routing."""
         for read_id in read_ids:
             self._queues.pop(read_id, None)
 
@@ -151,9 +151,7 @@ async def reopen_stream(
                     await self._recv_task
                 except (asyncio.CancelledError, Exception):
                     pass
-            error = _StreamError(
-                Exception("Stream reopening"), self._stream_generation
-            )
+            error = _StreamError(Exception("Stream reopening"), self._stream_generation)
             for queue in self._get_unique_queues():
                 self._put_error_nowait(queue, error)
             try:
@@ -171,8 +169,6 @@ async def close(self) -> None:
                 await self._recv_task
             except (asyncio.CancelledError, Exception):
                 pass
-        error = _StreamError(
-            Exception("Multiplexer closed"), self._stream_generation
-        )
+        error = _StreamError(Exception("Multiplexer closed"), self._stream_generation)
         for queue in self._get_unique_queues():
             self._put_error_nowait(queue, error)