From 736a949cb50f4f68f41491ebe19f65781670291e Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Sun, 3 Feb 2019 20:39:01 -0300 Subject: [PATCH] resume streams on startup --- lbrynet/stream/stream_manager.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/lbrynet/stream/stream_manager.py b/lbrynet/stream/stream_manager.py index 150af63ca..89b14fee3 100644 --- a/lbrynet/stream/stream_manager.py +++ b/lbrynet/stream/stream_manager.py @@ -142,11 +142,12 @@ class StreamManager: log.warning("no DHT node given, cannot resume downloads") return await self.node.joined.wait() - resumed = 0 - t = [self.start_stream(stream) for stream in self.streams if stream.status == ManagedStream.STATUS_RUNNING] - if resumed: - log.info("resuming %i downloads", t) - await asyncio.gather(*t, loop=self.loop) + t = [ + stream.start_download(self.node) + for stream in self.streams if stream.status == ManagedStream.STATUS_RUNNING + ] + if t: + log.info("resuming %i downloads", len(t)) async def reflect_streams(self): while True: