Merge pull request #604 from appwrite/fix-flutter-websocket-issues

appwrite · Feb 14, 2023 · a5decbf · a5decbf
2 parents 263ecd9 + 108f894
commit a5decbf
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/templates/flutter/lib/src/realtime_mixin.dart.twig b/templates/flutter/lib/src/realtime_mixin.dart.twig
@@ -76,6 +76,24 @@ mixin RealtimeMixin {
             }
             break;
         }
+      }, onDone: () {
+        for (var list in _channels.values) {
+          for (var stream in list) {
+            stream.close();
+          }
+        }
+        _channels.clear();
+        _closeConnection();
+      }, onError: (err, stack) {
+        for (var list in _channels.values) {
+          for (var stream in list) {
+            stream.sink.addError(err, stack);
+          }
+        }
+        if (_websok?.closeCode != null && _websok?.closeCode != 1008) {
+          debugPrint("Reconnecting in one second.");
+          Future.delayed(Duration(seconds: 1), _createSocket);
+        }
       });
     } catch (e) {
       if (e is {{spec.title | caseUcfirst}}Exception) {