Skip to content

Commit a5decbf

Browse files
Merge pull request appwrite#604 from appwrite/fix-flutter-websocket-issues
2 parents 263ecd9 + 108f894 commit a5decbf

File tree

1 file changed

+18
-0
lines changed

1 file changed

+18
-0
lines changed

templates/flutter/lib/src/realtime_mixin.dart.twig

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,24 @@ mixin RealtimeMixin {
7676
}
7777
break;
7878
}
79+
}, onDone: () {
80+
for (var list in _channels.values) {
81+
for (var stream in list) {
82+
stream.close();
83+
}
84+
}
85+
_channels.clear();
86+
_closeConnection();
87+
}, onError: (err, stack) {
88+
for (var list in _channels.values) {
89+
for (var stream in list) {
90+
stream.sink.addError(err, stack);
91+
}
92+
}
93+
if (_websok?.closeCode != null && _websok?.closeCode != 1008) {
94+
debugPrint("Reconnecting in one second.");
95+
Future.delayed(Duration(seconds: 1), _createSocket);
96+
}
7997
});
8098
} catch (e) {
8199
if (e is {{spec.title | caseUcfirst}}Exception) {

0 commit comments

Comments
 (0)