publish<T> method

Future<T> publish<T>({
  1. required String topic,
  2. required String message,
})

消息发布

Implementation

Future<T> publish<T>({required String topic, required String message}) async {
  if (!connected) throw Exception('MQTT 客户端未连接');
  // LogService.instance.reportMQTT('触发 MQTT 客户端 Publish <$topic> Topic', data: message);
  final completer = Completer<T>();
  _callbacks[topic] = completer;
  final builder = MqttPayloadBuilder();
  builder.addString(message);
  mqttClient?.publishMessage(topic, qos, builder.payload!);
  return completer.future;
}