Skip to content

Commit b64257b

Browse files
send back websocket done and error events through subscription
1 parent 8958ccf commit b64257b

File tree

1 file changed

+17
-0
lines changed

1 file changed

+17
-0
lines changed

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

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,23 @@ 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+
_closeConnection();
86+
}, onError: (err, stack) {
87+
for (var list in _channels.values) {
88+
for (var stream in list) {
89+
stream.sink.addError(err, stack);
90+
}
91+
}
92+
if (_websok?.closeCode != null && _websok?.closeCode != 1008) {
93+
debugPrint("Reconnecting in one second.");
94+
Future.delayed(Duration(seconds: 1), _createSocket);
95+
}
7996
});
8097
} catch (e) {
8198
if (e is {{spec.title | caseUcfirst}}Exception) {

0 commit comments

Comments
 (0)