We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d478cca commit b00ab42Copy full SHA for b00ab42
adafruit_minimqtt/adafruit_minimqtt.py
@@ -159,10 +159,13 @@ def __init__(
159
self._sock = None
160
self._backwards_compatible_sock = False
161
self._use_binary_mode = use_binary_mode
162
+
163
+ if recv_timeout <= socket_timeout:
164
+ raise MMQTTException("recv_timeout must be strictly greater than socket_timeout")
165
self._socket_timeout = socket_timeout
166
+ self._recv_timeout = recv_timeout
167
168
self.keep_alive = keep_alive
- self._recv_timeout = recv_timeout
169
self._user_data = None
170
self._is_connected = False
171
self._msg_size_lim = MQTT_MSG_SZ_LIM
0 commit comments