fix close youtube chat

LezdCS · May 30, 2024 · 296e0b6 · 296e0b6
1 parent 1210178
commit 296e0b6
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/lib/src/core/utils/youtube_chat.dart b/lib/src/core/utils/youtube_chat.dart
@@ -17,6 +17,10 @@ class YoutubeChat {
     this.videoId,
   );
 
+  void closeStream() {
+    _chatStreamController.close();
+  }
+
   // Function to fetch the initial continuation token
   Future<String?> fetchInitialContinuationToken() async {
     var headers = {
@@ -123,6 +127,7 @@ class YoutubeChat {
     }
 
     while (continuationToken != null) {
+      if(_chatStreamController.isClosed) return;
       continuationToken = await fetchChatMessages(continuationToken);
       await Future.delayed(const Duration(seconds: 5)); // 5-second pause
     }

diff --git a/lib/src/presentation/controllers/chat_view_controller.dart b/lib/src/presentation/controllers/chat_view_controller.dart
@@ -311,6 +311,7 @@ class ChatViewController extends GetxController
     }
 
     for (YoutubeChat y in youtubeChatToRemove) {
+      y.closeStream();
       youtubeChats.removeWhere((yc) => yc.videoId == y.videoId);
     }
   }