talksik/stream-chat-flutter
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

remove listener from channel

Browse Source
This commit is contained in:
Salvatore Giordano
2021-11-26 12:33:31 +01:00
parent 0dd9af0906
commit 577b731768
2 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/stream_chat/lib/src/client/channel.dart
-8
View File
@@ -1462,8 +1462,6 @@ class ChannelClientState {
_listenChannelUpdated(); _listenChannelUpdated();
_listenChannelDeleted();
_listenMemberAdded(); _listenMemberAdded();
_listenMemberRemoved(); _listenMemberRemoved();
@@ -1565,12 +1563,6 @@ class ChannelClientState {
})); }));
} }
void _listenChannelDeleted() {
_subscriptions.add(_channel.on(EventType.channelDeleted).listen((Event e) {
_channel.dispose();
}));
}
void _listenChannelTruncated() { void _listenChannelTruncated() {
_subscriptions.add(_channel _subscriptions.add(_channel
.on(EventType.channelTruncated, EventType.notificationChannelTruncated) .on(EventType.channelTruncated, EventType.notificationChannelTruncated)
packages/stream_chat/lib/src/client/client.dart
+2
View File
@@ -1432,6 +1432,8 @@ class ClientState {
.listen((Event event) async { .listen((Event event) async {
final eventChannel = event.channel!; final eventChannel = event.channel!;
await _client.chatPersistenceClient?.deleteChannels([eventChannel.cid]); await _client.chatPersistenceClient?.deleteChannels([eventChannel.cid]);
final channel = channels[eventChannel.cid];
channel?.dispose();
channels = channels..remove(eventChannel.cid); channels = channels..remove(eventChannel.cid);
})); }));
} }