diff --git a/src/connectrpc/_envelope.py b/src/connectrpc/_envelope.py index 5ee8a35..7867b20 100644 --- a/src/connectrpc/_envelope.py +++ b/src/connectrpc/_envelope.py @@ -53,7 +53,7 @@ def _read_messages(self) -> Iterator[_RES]: compressed = prefix_byte & 0b01 != 0 message_data = self._buffer[5 : 5 + self._next_message_length] - self._buffer = self._buffer[5 + self._next_message_length :] + del self._buffer[: 5 + self._next_message_length] self._next_message_length = None if compressed: if isinstance(self._compression, IdentityCompression):