completeを複数回呼ばないように

shiosyakeyakini-info · Dec 10, 2024 · c2170be · c2170be
1 parent c4979dc
commit c2170be
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/test/streaming_test.dart b/test/streaming_test.dart
@@ -508,7 +508,11 @@ void main() async {
           final id = DateTime.now().toIso8601String();
           final listener = controller.mainStream(id: id).listen((event) {
             final body = event.body;
-            if (body is ReadAllAnnouncementsChannelEvent) completer.complete();
+            if (body is ReadAllAnnouncementsChannelEvent) {
+              if (!completer.isCompleted) {
+                completer.complete();
+              }
+            }
           });
           await Future.wait(
             announcements.map((announcement) {