From 1a885d54e2803018cedc8a267cb3d39db30749de Mon Sep 17 00:00:00 2001 From: Marcel van der Veldt Date: Sat, 6 Jul 2024 12:57:32 +0200 Subject: [PATCH] cleanup --- music_assistant/server/helpers/multi_client_stream.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/music_assistant/server/helpers/multi_client_stream.py b/music_assistant/server/helpers/multi_client_stream.py index c0a9981b..bd31d63c 100644 --- a/music_assistant/server/helpers/multi_client_stream.py +++ b/music_assistant/server/helpers/multi_client_stream.py @@ -8,7 +8,6 @@ from contextlib import suppress from music_assistant.common.helpers.util import empty_queue from music_assistant.common.models.media_items import AudioFormat from music_assistant.server.helpers.audio import get_ffmpeg_stream -from music_assistant.server.helpers.util import TaskManager LOGGER = logging.getLogger(__name__) @@ -94,6 +93,4 @@ class MultiClientStream: *[sub.put(chunk) for sub in self.subscribers], return_exceptions=True ) # EOF: send empty chunk - async with TaskManager(self.mass) as tg: - for sub in list(self.subscribers): - tg.create_task(sub.put(b"")) + await asyncio.gather(*[sub.put(b"") for sub in self.subscribers], return_exceptions=True) -- 2.34.1