sync api: make sure threadloop is stopped even if disconnect failes

b05e0b27 · oroulet · oroulet · ecc3b1ad · b05e0b27
Commit b05e0b27 authored Sep 02, 2021 by oroulet Committed by oroulet Sep 02, 2021
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 3 deletions

asyncua/sync.py asyncua/sync.py +5 -3

No files found.
--- a/asyncua/sync.py
+++ b/asyncua/sync.py
@@ -174,9 +174,11 @@ class Client:
        pass

    def disconnect(self):
-        self.tloop.post(self.aio_obj.disconnect())
-        if self.close_tloop:
-            self.tloop.stop()
+        try:
+            self.tloop.post(self.aio_obj.disconnect())
+        finally:
+            if self.close_tloop:
+                self.tloop.stop()

    def set_user(self, username: str):
        self.aio_obj.set_user(username)