Simply watchers logic
This commit is contained in:
@@ -2115,16 +2115,9 @@ class ChannelClientState {
|
|||||||
.toList();
|
.toList();
|
||||||
|
|
||||||
/// Channel watchers list as a stream.
|
/// Channel watchers list as a stream.
|
||||||
Stream<List<User>> get watchersStream => CombineLatestStream.combine2<
|
Stream<List<User>?> get watchersStream => channelStateStream
|
||||||
List<User>?, Map<String?, User?>, List<User>>(
|
.map((cs) => cs.watchers)
|
||||||
channelStateStream
|
.where((watchers) => watchers != null);
|
||||||
.map((cs) => cs.watchers)
|
|
||||||
.where((watchers) => watchers != null),
|
|
||||||
_channel.client.state.usersStream,
|
|
||||||
(watchers, users) {
|
|
||||||
return watchers!.map((e) => users[e.id] ?? e).toList();
|
|
||||||
} ,
|
|
||||||
);
|
|
||||||
|
|
||||||
/// Channel member for the current user.
|
/// Channel member for the current user.
|
||||||
Member? get currentUserMember => members.firstWhereOrNull(
|
Member? get currentUserMember => members.firstWhereOrNull(
|
||||||
|
|||||||
Reference in New Issue
Block a user