diff options
| -rw-r--r-- | lib/data.dart | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/lib/data.dart b/lib/data.dart index f5a24e8..38fd564 100644 --- a/lib/data.dart +++ b/lib/data.dart @@ -32,11 +32,14 @@ class AppState with ChangeNotifier { _client.port = brokerPort; _client.keepAlivePeriod = 2; + _client.autoReconnect = true; _client.disconnectOnNoResponsePeriod = 1; _client.logging(on: false); _client.onConnected = _onConnected; _client.onDisconnected = _onDisconnected; + _client.onAutoReconnect = _onAutoReconnect; + _client.onAutoReconnected = _onAutoReconnected; try { await _client.connect(); @@ -59,6 +62,16 @@ class AppState with ChangeNotifier { notifyListeners(); } + void _onAutoReconnect() { + _brokerConnected = false; + notifyListeners(); + } + + void _onAutoReconnected() { + _brokerConnected = true; + notifyListeners(); + } + void _onMessage(List<MqttReceivedMessage<MqttMessage>> messages) { for (final MqttReceivedMessage<MqttMessage> message in messages) { final String topic = message.topic; |