From 9b51cf079b6e6d7b688b4eaa24d7018c76678065 Mon Sep 17 00:00:00 2001
From: DevilXD <bartosz.peszek@gmail.com>
Date: Fri, 14 Jan 2022 18:52:55 +0100
Subject: [PATCH] Make sure watch task is protected by task_wrapper

---
 twitch.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/twitch.py b/twitch.py
index aa5bec4..259c051 100644
--- a/twitch.py
+++ b/twitch.py
@@ -316,6 +316,7 @@ class Twitch:
                         self.change_state(State.CHANNELS_CLEANUP)
             await self._state_change.wait()
 
+    @task_wrapper
     async def _watch_loop(self) -> None:
         interval = WATCH_INTERVAL.total_seconds()
         i = 1
@@ -396,6 +397,7 @@ class Twitch:
             self.gui.channels.set_watching(channel)
             self._watching_restart.set()
 
+    @task_wrapper
     async def process_stream_state(self, channel_id: int, message: JsonType):
         msg_type = message["type"]
         channel = self.channels.get(channel_id)