Skip to content

Commit c057ac6

Browse files
authored
use mutable bytearray instead of bytes as buffer (#152)
1 parent bfe9df3 commit c057ac6

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

hazelcast/connection.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -271,7 +271,7 @@ def __init__(self, address, connection_closed_callback, message_callback):
271271
self.logger = logging.getLogger("Connection[%s](%s:%d)" % (self.id, address.host, address.port))
272272
self._connection_closed_callback = connection_closed_callback
273273
self._builder = ClientMessageBuilder(message_callback)
274-
self._read_buffer = b""
274+
self._read_buffer = bytearray()
275275
self.last_read_in_seconds = 0
276276
self.last_write_in_seconds = 0
277277
self.start_time_in_seconds = 0

hazelcast/reactor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ def handle_connect(self):
186186
self.logger.debug("Connected to %s", self._address)
187187

188188
def handle_read(self):
189-
self._read_buffer += self.recv(BUFFER_SIZE)
189+
self._read_buffer.extend(self.recv(BUFFER_SIZE))
190190
self.last_read_in_seconds = time.time()
191191
self.receive_message()
192192

0 commit comments

Comments
 (0)