fix(unetpy): minor fix in the receive method

org-arl · Sep 8, 2019 · efe6034 · efe6034
1 parent 79f03cc
commit efe6034
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/contrib/Unet-Python-API/unetpy/__init__.py b/contrib/Unet-Python-API/unetpy/__init__.py
@@ -449,7 +449,7 @@ def receive(self):
             elif self.timeout > 0:
                 deadline = int(round(_time.time() * 1000)) + self.timeout
             ntf = None
-            while self.waiting.wait():
+            while not self.waiting.is_set():
                 timeRemaining = -1
                 if self.timeout == 0:
                     timeRemaining = 0
@@ -469,7 +469,6 @@ def receive(self):
                         if (self.localProtocol == p):
                             return dg
         except:
-            self.waiting.clear()
             self.waiting = None
         return None