diff --git a/lib/flutter_client_sse.dart b/lib/flutter_client_sse.dart
index 57db0b3..f73a459 100644
--- a/lib/flutter_client_sse.dart
+++ b/lib/flutter_client_sse.dart
@@ -140,6 +140,10 @@ class SSEClient {
                   streamController: streamController,
                 );
               },
+              onDone: () {
+                print('---STREAM DONE---');
+                streamController.close();
+              },
             );
         }, onError: (e, s) {
           print('---ERROR---');