Add retry logic

CHANGELOG.md

@@ -1,3 +1,10 @@
+## 3.0.0
+
+- Add retry logic.
+
+** Possible Breaking Change ** Error messages may now be delayed up to 5 seconds
+in the client.
+
 ## 2.1.2
 
 - Remove `package:http` dependency.

lib/client/sse_client.dart

@@ -25,6 +25,8 @@ class SseClient extends StreamChannelMixin<String> {
 
   String _serverUrl;
 
+  Timer _errorTimer;
+
   /// [serverUrl] is the URL under which the server is listening for
   /// incoming bi-directional SSE connections.
   SseClient(String serverUrl) {
@@ -36,7 +38,20 @@ class SseClient extends StreamChannelMixin<String> {
         .listen(_onOutgoingMessage, onDone: _onOutgoingDone);
     _eventSource.addEventListener('message', _onIncomingMessage);
     _eventSource.addEventListener('control', _onIncomingControlMessage);
-    _eventSource.onError.listen(_incomingController.addError);
+    _eventSource.onOpen.listen((_) {
+      _errorTimer?.cancel();
+    });
+    _eventSource.onError.listen((error) {
+      if (!(_errorTimer?.isActive ?? false)) {
+        // By default the SSE client uses keep-alive.
+        // Allow for a retry to connect before giving up.
+        _errorTimer = Timer(const Duration(seconds: 5), () {
+          _incomingController.addError(error);
+          _eventSource.close();
+        });
+      }
+    });
+
     _startPostingMessages();
   }
 

pubspec.yaml

@@ -1,5 +1,5 @@
 name: sse
-version: 2.1.2
+version: 3.0.0
 author: Dart Team <[email protected]>
 homepage: https://github.com/dart-lang/sse
 description: >-