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

migrate channels_bloc

Browse Source
This commit is contained in:
Neevash Ramdial
2021-04-20 10:35:40 +02:00
committed by Salvatore Giordano
parent e52e79bafa
commit 8f7471fec2
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/stream_chat_flutter_core/lib/src/channels_bloc.dart
+5 -7
View File
@@ -104,9 +104,7 @@ class ChannelsBlocState extends State<ChannelsBloc>
} }
try { try {
final clear = paginationParams == null || final clear = paginationParams == null || paginationParams.offset == 0;
paginationParams.offset == null ||
paginationParams.offset == 0;
final oldChannels = List<Channel>.from(channels ?? []); final oldChannels = List<Channel>.from(channels ?? []);
var newChannels = <Channel>[]; var newChannels = <Channel>[];
await for (final channels in client.queryChannels( await for (final channels in client.queryChannels(
@@ -162,9 +160,9 @@ class ChannelsBlocState extends State<ChannelsBloc>
newChannels.insert(0, _hiddenChannels[hiddenIndex]); newChannels.insert(0, _hiddenChannels[hiddenIndex]);
_hiddenChannels.removeAt(hiddenIndex); _hiddenChannels.removeAt(hiddenIndex);
} else { } else {
if (client.state?.channels != null && if (client.state.channels != null &&
client.state?.channels[e.cid] != null) { client.state.channels?[e.cid] != null) {
newChannels.insert(0, client.state.channels[e.cid]); newChannels.insert(0, client.state.channels?[e.cid]);
} }
} }
} }
@@ -195,7 +193,7 @@ class ChannelsBlocState extends State<ChannelsBloc>
// ignore: cascade_invocations // ignore: cascade_invocations
final channel = e.channel; final channel = e.channel;
_channelsController.add(List.from( _channelsController.add(List.from(
(channels ?? [])..removeWhere((c) => c.cid == channel.cid))); (channels ?? [])..removeWhere((c) => c.cid == channel?.cid)));
})); }));
} }