Resume reading only in read

Author: NoahStapp

pymongo/network_layer.py

@@ -512,23 +512,23 @@ async def write(self, message: bytes) -> None:
         if self.transport.is_closing():
             raise OSError("Connection is closed")
         self.transport.write(message)
-        self.transport.resume_reading()
+        # self.transport.resume_reading()
 
     async def read(self, request_id: Optional[int], max_message_size: int) -> tuple[bytes, int]:
         """Read a single MongoDB Wire Protocol message from this connection."""
+        self._request_id = request_id
         if self.transport:
             try:
                 self.transport.resume_reading()
             # Known bug in SSL Protocols, fixed in Python 3.11: https://github.com/python/cpython/issues/89322
             except AttributeError:
                 raise OSError("connection is already closed") from None
         self._max_message_size = max_message_size
-        self._request_id = request_id
         if self._done_messages:
             message = await self._done_messages.popleft()
         else:
-            # if self.transport and self.transport.is_closing():
-            #     raise OSError("connection is already closed")
+            if self.transport and self.transport.is_closing():
+                raise OSError("connection is already closed")
             read_waiter = asyncio.get_running_loop().create_future()
             self._pending_messages.append(read_waiter)
             try: