Appwrite/sdk-for-flutter
1
0
Fork 0
mirror of https://github.com/appwrite/sdk-for-flutter.git synced 2026-04-07 19:27:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

pass back when websocket is done or error occurs

Browse Source
This commit is contained in:
Damodar Lohani
2023-01-11 10:32:43 +05:45
parent e5236a1375
commit 281e5d553f
1 changed files with 22 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/src/realtime_mixin.dart
+22 -5
View File
@@ -67,15 +67,32 @@ mixin RealtimeMixin {
break;
case 'event':
final message = RealtimeMessage.fromMap(data.data);
for(var channel in message.channels) {
for (var channel in message.channels) {
if (_channels[channel] != null) {
for( var stream in _channels[channel]!) {
for (var stream in _channels[channel]!) {
stream.sink.add(message);
}
}
}
break;
}
}, onDone: () {
for (var list in _channels.values) {
for (var stream in list) {
stream.close();
}
}
_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 AppwriteException) {
@@ -108,7 +125,7 @@ mixin RealtimeMixin {
RealtimeSubscription subscribeTo(List<String> channels) {
StreamController<RealtimeMessage> controller = StreamController.broadcast();
for(var channel in channels) {
for (var channel in channels) {
if (!_channels.containsKey(channel)) {
_channels[channel] = [];
}
@@ -119,13 +136,13 @@ mixin RealtimeMixin {
stream: controller.stream,
close: () async {
controller.close();
for(var channel in channels) {
for (var channel in channels) {
_channels[channel]!.remove(controller);
if (_channels[channel]!.isEmpty) {
_channels.remove(channel);
}
}
if(_channels.isNotEmpty) {
if (_channels.isNotEmpty) {
await Future.delayed(Duration.zero, () => _createSocket());
} else {
await _closeConnection();