handle the already closed case

Author: blink1073

pymongo/network_layer.py

@@ -338,6 +338,8 @@ async def read(self, request_id: Optional[int], max_message_size: int) -> tuple[
         if self._done_messages:
             message = await self._done_messages.popleft()
         else:
+            if self._closing_exception:
+                raise self._closing_exception
             read_waiter = asyncio.get_running_loop().create_future()
             self._pending_messages.append(read_waiter)
             try: