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 f6cfd51 commit 0c2ac47Copy full SHA for 0c2ac47
src/paho/mqtt/client.py
@@ -345,10 +345,10 @@ def wait_for_publish(self, timeout=None):
345
elif self.rc > 0:
346
raise RuntimeError('Message publish failed: %s' % (error_string(self.rc)))
347
348
- timeout_time = None if not timeout else time.time() + timeout
349
- timeout_tenth = None if not timeout else timeout / 10.
+ timeout_time = None if timeout is None else time.time() + timeout
+ timeout_tenth = None if timeout is None else timeout / 10.
350
def timed_out():
351
- return False if not timeout else time.time() > timeout_time
+ return False if timeout is None else time.time() > timeout_time
352
353
with self._condition:
354
while not self._published and not timed_out():
0 commit comments