initListener method
void
initListener(
)
override
Implementation
@override
void initListener() {
subscriptions.add(NimCore.instance.messageService.onSyncStickTopSession
.listen((event) async {
await _updateStickTopSessionList();
_stickTopStream.add(event);
}));
subscriptions.add(
NimCore.instance.messageService.onStickTopSessionAdd.listen((event) {
stickTopSessionList?.add(event);
}));
subscriptions.add(
NimCore.instance.messageService.onStickTopSessionRemove.listen((event) {
stickTopSessionList?.removeWhere((element) =>
element.sessionId == event.sessionId &&
element.sessionType == event.sessionType);
}));
//添加对群变化的监听,删除会话置顶的群
subscriptions
.add(NimCore.instance.teamService.onTeamListRemove.listen((teamList) {
for (var team in teamList) {
stickTopSessionList?.removeWhere((element) =>
element.sessionId == team.id &&
element.sessionType == NIMSessionType.team);
}
}));
}