subscribeChatRoom method

void subscribeChatRoom(
  1. QChatRoom room
)

Implementation

void subscribeChatRoom(QChatRoom room) async {
  await _doOnConnected(() {
    var roomId = room.id.toString();
    // var state = _mqtt.connectionStatus?.state.toString();
    var subs1 =
        mqttSubscribeTopic(TopicBuilder.messageRead(roomId)).run(_mqtt);
    var subs2 =
        mqttSubscribeTopic(TopicBuilder.messageDelivered(roomId)).run(_mqtt);
    var subs3 =
        mqttSubscribeTopic(TopicBuilder.typing(roomId, '+')).run(_mqtt);

    subs1.runOrThrow();
    subs2.runOrThrow();
    subs3.runOrThrow();
  });
}