From ef12e1dc11cb137db34042b936cfb8c9d954709e Mon Sep 17 00:00:00 2001 From: Salvatore Giordano Date: Thu, 29 Jul 2021 13:18:23 +0200 Subject: [PATCH] readd event.me listener --- packages/stream_chat/lib/src/client/client.dart | 15 +++++++++++++++ .../stream_chat_flutter/lib/src/stream_chat.dart | 1 - 2 files changed, 15 insertions(+), 1 deletion(-) diff --git a/packages/stream_chat/lib/src/client/client.dart b/packages/stream_chat/lib/src/client/client.dart index b25ebe88..8507423b 100644 --- a/packages/stream_chat/lib/src/client/client.dart +++ b/packages/stream_chat/lib/src/client/client.dart @@ -1334,6 +1334,21 @@ class ClientState { /// Creates a new instance listening to events and updating the state ClientState(this._client) { _subscriptions.addAll([ + _client + .on() + .where((event) => + event.me != null && event.type != EventType.healthCheck) + .map((e) => e.me!) + .listen((user) { + currentUser = user; + final totalUnreadCount = user.totalUnreadCount; + _totalUnreadCountController.add(totalUnreadCount); + + final unreadChannels = user.unreadChannels; + if (unreadChannels != null) { + _unreadChannelsController.add(unreadChannels); + } + }), _client .on() .map((event) => event.unreadChannels) diff --git a/packages/stream_chat_flutter/lib/src/stream_chat.dart b/packages/stream_chat_flutter/lib/src/stream_chat.dart index b3654a31..f185d288 100644 --- a/packages/stream_chat_flutter/lib/src/stream_chat.dart +++ b/packages/stream_chat_flutter/lib/src/stream_chat.dart @@ -1,5 +1,4 @@ import 'dart:async'; -import 'dart:ui' as ui; import 'package:flutter/foundation.dart'; import 'package:flutter/material.dart';