We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 998b942 commit 72758c6Copy full SHA for 72758c6
1 file changed
databento/live/protocol.py
@@ -255,7 +255,7 @@ def buffer_updated(self, nbytes: int) -> None:
255
256
"""
257
logger.debug("read %d bytes from remote gateway", nbytes)
258
- data = self.__buffer[:nbytes]
+ data = bytes(memoryview(self.__buffer)[:nbytes])
259
260
if self.authenticated.done():
261
self._process_dbn(data)
@@ -375,7 +375,7 @@ def _process_dbn(self, data: bytes) -> None:
375
raise ValueError("not connected")
376
377
try:
378
- self._dbn_decoder.write(bytes(data))
+ self._dbn_decoder.write(data)
379
records = self._dbn_decoder.decode()
380
except Exception:
381
logger.exception("error decoding DBN record")
0 commit comments