Skip to content

Commit 506527f

Browse files
committed
Test removing transport.is_closing check
1 parent b69688b commit 506527f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pymongo/network_layer.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -527,8 +527,8 @@ async def read(self, request_id: Optional[int], max_message_size: int) -> tuple[
527527
if self._done_messages:
528528
message = await self._done_messages.popleft()
529529
else:
530-
if self.transport and self.transport.is_closing():
531-
raise OSError("connection is already closed")
530+
# if self.transport and self.transport.is_closing():
531+
# raise OSError("connection is already closed")
532532
read_waiter = asyncio.get_running_loop().create_future()
533533
self._pending_messages.append(read_waiter)
534534
try:

0 commit comments

Comments
 (0)