subscribeChatRoom method
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();
});
}