エラー時の処理を修正

shiosyakeyakini-info · Oct 18, 2024 · 353fa08 · 353fa08
1 parent 90d0aa0
commit 353fa08
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/lib/src/services/streaming_service_impl.dart b/lib/src/services/streaming_service_impl.dart
@@ -125,6 +125,12 @@ class StreamingService implements StreamingController, WebSocketController {
       if (retryCounts < maxRetryCounts) {
         await _reconnect(retryCounts: retryCounts + 1);
       } else {
+        _subNotes.clear();
+        try {
+          await _close();
+        } catch (e) {
+          print(e);
+        }
         rethrow;
       }
     }
@@ -145,6 +151,7 @@ class StreamingService implements StreamingController, WebSocketController {
     } finally {
       _subscription = null;
       _webSocketChannel = null;
+      _subNotes.clear();
     }
   }