From 63d1ec3c28627e4d5359df5a46e6f39f76e13d15 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Tue, 5 Feb 2019 13:00:57 -0300 Subject: [PATCH] fixes from jack comments --- lbrynet/stream/assembler.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lbrynet/stream/assembler.py b/lbrynet/stream/assembler.py index 296686c6d..8b11ecb7e 100644 --- a/lbrynet/stream/assembler.py +++ b/lbrynet/stream/assembler.py @@ -89,12 +89,12 @@ class StreamAssembler: with open(self.output_path, 'wb') as stream_handle: self.stream_handle = stream_handle for blob_info in self.descriptor.blobs[:-1]: - while True: + while not stream_handle.closed: try: blob = await self.get_blob(blob_info.blob_hash, blob_info.length) if await self._decrypt_blob(blob, blob_info, self.descriptor.key): await self.blob_manager.blob_completed(blob) - break + break except FileNotFoundError: log.debug("stream assembler stopped") return