diff --git a/lib/src/channels_bloc.dart b/lib/src/channels_bloc.dart index a58759ab..d21d7cea 100644 --- a/lib/src/channels_bloc.dart +++ b/lib/src/channels_bloc.dart @@ -140,6 +140,13 @@ class ChannelsBlocState extends State await channel.watch(); _channelsController.add(List.from(channels..insert(0, channel))); })); + + _subscriptions.add( + client.on(EventType.notificationRemovedFromChannel).listen((e) async { + final channelModel = e.channel; + _channelsController.add( + List.from(channels..removeWhere((c) => c.cid == channelModel.cid))); + })); } @override