bindWsEvents method

void bindWsEvents()

Implementation

void bindWsEvents() {
  _sub?.cancel();
  _sub = _net.ws.eventStream.listen((frame) async {
    if (frame.event != WsEvents.conversationDeleted) return;
    final p = frame.payloadMap ?? {};
    final talkMode = asInt(p['talk_mode']);
    final toFromId = asInt(p['to_from_id']);
    if (talkMode <= 0 || toFromId <= 0) return;
    await _store.deleteConversation(talkMode, toFromId);
    _listener?.conversationDeleted('$talkMode-$toFromId');
    await _notifyTotalUnread();
  });
}