w
This commit is contained in:
@@ -281,18 +281,6 @@ class TimepixFlyBackend:
|
||||
self._decode_received_data(entry + "}")
|
||||
buffer = buffer_chunks[-1] # Keep the last incomplete chunk in the buffer
|
||||
|
||||
# if "}\n" in buffer:
|
||||
# buffer_chunks = buffer.split("}\n")
|
||||
# processed_chunks = 0
|
||||
# for entry in buffer_chunks:
|
||||
# if entry and entry.endswith("}\n"):
|
||||
# self._decode_received_data(entry + "}")
|
||||
# processed_chunks += 1
|
||||
# if processed_chunks == len(buffer_chunks):
|
||||
# buffer = ""
|
||||
# else:
|
||||
# buffer = buffer_chunks[-1]
|
||||
|
||||
def _decode_received_data(self, buffer: str) -> None:
|
||||
"""
|
||||
Decode the received data from the socket.
|
||||
|
||||
Reference in New Issue
Block a user