File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -139,6 +139,7 @@ class MQTT:
139
139
:param int socket_timeout: How often to check socket state for read/write/connect operations,
140
140
in seconds.
141
141
:param int connect_retries: How many times to try to connect to broker before giving up.
142
+ :param class user_data: arbitrary data to pass as a second argument to the callbacks.
142
143
143
144
"""
144
145
@@ -159,6 +160,7 @@ def __init__(
159
160
use_binary_mode = False ,
160
161
socket_timeout = 1 ,
161
162
connect_retries = 5 ,
163
+ user_data = None ,
162
164
):
163
165
164
166
self ._socket_pool = socket_pool
@@ -176,7 +178,7 @@ def __init__(
176
178
self ._connect_retries = connect_retries
177
179
178
180
self .keep_alive = keep_alive
179
- self ._user_data = None
181
+ self ._user_data = user_data
180
182
self ._is_connected = False
181
183
self ._msg_size_lim = MQTT_MSG_SZ_LIM
182
184
self ._pid = 0
You can’t perform that action at this time.
0 commit comments