@@ -145,10 +145,9 @@ def __init__(
145
145
ssl_context = None
146
146
):
147
147
# Socket Pool
148
- if socket_pool is not None :
148
+ if socket_pool :
149
149
self ._socket_pool = socket_pool
150
- if ssl_context is not None :
151
- self ._ssl_context = ssl_context
150
+ self ._ssl_context = ssl_context
152
151
# Hang onto open sockets so that we can reuse them
153
152
self ._socket_free = {}
154
153
self ._open_sockets = {}
@@ -165,19 +164,19 @@ def __init__(
165
164
self ._username = username
166
165
self ._password = password
167
166
if (
168
- self ._password is not None
167
+ self ._password
169
168
and len (password .encode ("utf-8" )) > MQTT_TOPIC_LENGTH_LIMIT
170
169
): # [MQTT-3.1.3.5]
171
170
raise MMQTTException ("Password length is too large." )
172
171
173
172
self .port = MQTT_TCP_PORT
174
173
if is_ssl :
175
174
self .port = MQTT_TLS_PORT
176
- if port is not None :
175
+ if port :
177
176
self .port = port
178
177
179
178
# define client identifer
180
- if client_id is not None :
179
+ if client_id :
181
180
# user-defined client_id MAY allow client_id's > 23 bytes or
182
181
# non-alpha-numeric characters
183
182
self .client_id = client_id
@@ -252,7 +251,6 @@ def _get_socket(self, host, port, *, timeout=1):
252
251
raise RuntimeError (
253
252
"ssl_context must be set before using adafruit_mqtt for secure MQTT."
254
253
)
255
- print (key )
256
254
addr_info = self ._socket_pool .getaddrinfo (
257
255
host , port , 0 , self ._socket_pool .SOCK_STREAM
258
256
)[0 ]
0 commit comments