initListener method

  1. @override
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);
    }
  }));
}