Explorar o código

Check for done to prevent explosion (#102)

Scott Weber %!s(int64=2) %!d(string=hai) anos
pai
achega
9d625c19eb
Modificáronse 1 ficheiros con 2 adicións e 1 borrados
  1. 2 1
      mauigpapi/mqtt/conn.py

+ 2 - 1
mauigpapi/mqtt/conn.py

@@ -297,7 +297,8 @@ class AndroidMQTT:
             self.log.trace(f"Got publish confirmation for {mid}, but no waiters")
             self.log.trace(f"Got publish confirmation for {mid}, but no waiters")
             return
             return
         self.log.trace(f"Got publish confirmation for {mid}")
         self.log.trace(f"Got publish confirmation for {mid}")
-        waiter.set_result(None)
+        if not waiter.done():
+            waiter.set_result(None)
 
 
     # region Incoming event parsing
     # region Incoming event parsing