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

fix(llc): ignore healthcheck user.me objects

Browse Source
This commit is contained in:
Salvatore Giordano
2021-07-23 09:42:59 +02:00
parent 4f768024c6
commit 9ebd8c7876
1 changed files with 7 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/stream_chat/lib/src/client/client.dart
+7 -11
View File
@@ -388,9 +388,6 @@ class StreamChatClient {
} }
void _handleHealthCheckEvent(Event event) { void _handleHealthCheckEvent(Event event) {
final user = event.me;
if (user != null) state.user = user;
final connectionId = event.connectionId; final connectionId = event.connectionId;
if (connectionId != null) { if (connectionId != null) {
_connectionIdManager.setConnectionId(connectionId); _connectionIdManager.setConnectionId(connectionId);
@@ -1333,16 +1330,15 @@ class ClientState {
_subscriptions.addAll([ _subscriptions.addAll([
_client _client
.on() .on()
.where((event) => event.me != null) .where((event) =>
.map((e) => e.me) event.me != null && event.type != EventType.healthCheck)
.map((e) => e.me!)
.listen((user) { .listen((user) {
_userController.add(user); this.user = user;
final totalUnreadCount = user?.totalUnreadCount; final totalUnreadCount = user.totalUnreadCount;
if (totalUnreadCount != null) { _totalUnreadCountController.add(totalUnreadCount);
_totalUnreadCountController.add(totalUnreadCount);
}
final unreadChannels = user?.unreadChannels; final unreadChannels = user.unreadChannels;
if (unreadChannels != null) { if (unreadChannels != null) {
_unreadChannelsController.add(unreadChannels); _unreadChannelsController.add(unreadChannels);
} }