Skip to content

Commit 88baf83

Browse files
committed
check socket timeout against receive timeout
1 parent 9b250e4 commit 88baf83

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

adafruit_minimqtt/adafruit_minimqtt.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -159,10 +159,13 @@ def __init__(
159159
self._sock = None
160160
self._backwards_compatible_sock = False
161161
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")
162165
self._socket_timeout = socket_timeout
166+
self._recv_timeout = recv_timeout
163167

164168
self.keep_alive = keep_alive
165-
self._recv_timeout = recv_timeout
166169
self._user_data = None
167170
self._is_connected = False
168171
self._msg_size_lim = MQTT_MSG_SZ_LIM

0 commit comments

Comments
 (0)