diff --git a/api/src/dooris_api/mqtt_client.py b/api/src/dooris_api/mqtt_client.py index a090c5f..505588a 100644 --- a/api/src/dooris_api/mqtt_client.py +++ b/api/src/dooris_api/mqtt_client.py @@ -78,6 +78,10 @@ class AsyncMqttClient: self.client.on_subscribe = self.on_subscribe self.client.on_unsubscribe = self.on_unsubscribe self.client.on_disconnect = self.on_disconnect + self.fut_disconnect = None + self.fut_connected = None + self.fut_subscribe = None + self.fut_unsubscribe = None def on_connect( self,