summaryrefslogtreecommitdiff
path: root/dedup/compression.py
diff options
context:
space:
mode:
Diffstat (limited to 'dedup/compression.py')
-rw-r--r--dedup/compression.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/dedup/compression.py b/dedup/compression.py
index 9cd63e5..6d361ac 100644
--- a/dedup/compression.py
+++ b/dedup/compression.py
@@ -110,8 +110,9 @@ class DecompressedStream:
data = self.fileobj.read(self.blocksize)
if data:
self.buff += self.decompressor.decompress(data)
- elif hasattr(self.decompressor, "flush"):
- self.buff += self.decompressor.flush()
+ else:
+ if hasattr(self.decompressor, "flush"):
+ self.buff += self.decompressor.flush()
break
def _read_from_buff(self, length):