FIX: Stream identification hang #189

- fixed termination condition in `blocking_read`.
openpreserve · May 15, 2020 · 14932c5 · 14932c5
1 parent e59b8e4
commit 14932c5
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/fido/fido.py b/fido/fido.py
@@ -512,10 +512,11 @@ def blocking_read(self, file, bytes_to_read):
         buffer = b''
         while bytes_read < bytes_to_read:
             readbuffer = file.read(bytes_to_read - bytes_read)
+            last_read_len = len(readbuffer)
             buffer += readbuffer
-            bytes_read = len(buffer)
-            # break out if EOF is reached.
-            if readbuffer == '':
+            bytes_read += last_read_len
+            # break out if EOF is reached, that is zero bytes read.
+            if last_read_len < 1:
                 break
         return buffer