We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 36fb9cf commit b5ac22dCopy full SHA for b5ac22d
pymongo/network_layer.py
@@ -611,7 +611,8 @@ def buffer_updated(self, nbytes: int) -> None:
611
done.set_result((self._start, self._body_length + self._start, self._op_code))
612
self._start += self._body_length
613
self._done_messages.append(done)
614
- if self._length - self._start > self._body_length:
+ # If we have more data after processing the last message, start processing a new message
615
+ if self._length - self._start > 0:
616
self._read_waiter = asyncio.get_running_loop().create_future()
617
self._pending_messages.append(self._read_waiter)
618
extra = self._length - self._start
0 commit comments