close時もリスナーをクリアする、クローズに失敗しても再読込する

shiosyakeyakini-info · Aug 28, 2023 · 2913789 · 2913789
1 parent e430a65
commit 2913789
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/src/services/streaming_service.dart b/lib/src/services/streaming_service.dart
@@ -170,6 +170,7 @@ class StreamingService {
   }
 
   Future<void> close() async {
+    streamingChannelControllers.clear();
     await Future.wait([
       subscription?.cancel() ?? Future.value(),
       webSocketChannel.sink.close(),
@@ -179,7 +180,11 @@ class StreamingService {
   }
 
   Future<void> restart() async {
-    await close();
+    try {
+      await close();
+    } catch (e) {
+      print("already closed");
+    }
     startStreaming();
   }
 }