diff --git a/lib/flutter_client_sse.dart b/lib/flutter_client_sse.dart
index c243951..34a3ce6 100644
--- a/lib/flutter_client_sse.dart
+++ b/lib/flutter_client_sse.dart
@@ -23,6 +23,7 @@ class SSEClient {
       required Map<String, String> header,
       Map<String, dynamic>? body}) {
     print('---RETRY CONNECTION---');
+    if (!_streamController.isClosed)
     Future.delayed(Duration(seconds: 5), () {
       subscribeToSSE(
         method: method,