Skip to content

Commit 507d50e

Browse files
Fix bug with read write stream
1 parent 02e4e97 commit 507d50e

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

runner/precise_runner/runner.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,8 +87,11 @@ def read(self, n=-1, timeout=None):
8787
if n == -1:
8888
n = len(self.buffer)
8989
if 0 < self.chop_samples < len(self.buffer):
90-
self.buffer = self.buffer[self.chop_samples:]
91-
return_time = time.time() + (float('inf') if timeout is None else timeout)
90+
samples_left = len(self.buffer) % self.chop_samples
91+
self.buffer = self.buffer[-samples_left:]
92+
return_time = 1e10 if timeout is None else (
93+
timeout + time.time()
94+
)
9295
while len(self.buffer) < n:
9396
self.write_event.clear()
9497
if not self.write_event.wait(return_time - time.time()):

0 commit comments

Comments
 (0)