24
24
"""
25
25
try :
26
26
from typing import Tuple , Callable , Optional , Any
27
+ from adafruit_io .adafruit_io import IO_MQTT
27
28
except ImportError :
28
29
pass
29
30
34
35
import digitalio
35
36
from adafruit_display_shapes .rect import Rect
36
37
from adafruit_display_text .label import Label
37
- from adafruit_io .adafruit_io import IO_MQTT
38
38
39
39
__version__ = "0.0.0+auto.0"
40
40
__repo__ = "https://github.com/adafruit/Adafruit_CircuitPython_Dash_Display.git"
@@ -163,7 +163,7 @@ def __init__(
163
163
self .display .show (self .splash )
164
164
165
165
def simple_text_callback (
166
- self , client : Any , feed_id : str , message : str
166
+ self , client : IO_MQTT , feed_id : str , message : str
167
167
): # pylint: disable=unused-argument
168
168
"""Default callback function that uses the text in the Feed object and the color callback
169
169
to set the text"""
@@ -175,7 +175,7 @@ def simple_text_callback(
175
175
text = feed .text .format (float (message ))
176
176
return text
177
177
178
- def update_text (self , client : Any , feed_id : str , message : str ):
178
+ def update_text (self , client : IO_MQTT , feed_id : str , message : str ):
179
179
"""Updates the text on the display"""
180
180
feed = self .feeds [feed_id ]
181
181
feed .callback (client , feed_id , message )
@@ -252,21 +252,21 @@ def get(self):
252
252
253
253
# pylint: disable=unused-argument
254
254
@staticmethod
255
- def connected (client : Any ):
255
+ def connected (client : IO_MQTT ):
256
256
"""Callback for when the device is connected to Adafruit IO"""
257
257
print ("Connected to Adafruit IO!" )
258
258
259
259
@staticmethod
260
- def subscribe (client : Any , userdata : Any , topic : str , granted_qos : str ):
260
+ def subscribe (client : IO_MQTT , userdata : Any , topic : str , granted_qos : str ):
261
261
"""Callback for when a new feed is subscribed to"""
262
262
print ("Subscribed to {0} with QOS level {1}" .format (topic , granted_qos ))
263
263
264
264
@staticmethod
265
- def disconnected (client : Any ):
265
+ def disconnected (client : IO_MQTT ):
266
266
"""Callback for when the device disconnects from Adafruit IO"""
267
267
print ("Disconnected from Adafruit IO!" )
268
268
269
- def message (self , client : Any , feed_id : str , message : str ):
269
+ def message (self , client : IO_MQTT , feed_id : str , message : str ):
270
270
"""Callback for whenever a new message is received"""
271
271
print ("Feed {0} received new value: {1}" .format (feed_id , message ))
272
272
feed_id = feed_id .split ("/" )[- 1 ]
0 commit comments