Updated connect_sessionless and connect_socket

to start new thread if necessary
FreeOpcUa · Dec 12, 2023 · 8dab330 · 8dab330
1 parent 5846fea
commit 8dab330
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/asyncua/sync.py b/asyncua/sync.py
@@ -263,9 +263,12 @@ def disconnect(self) -> None:
             if self.close_tloop:
                 self.tloop.stop()
 
-    @syncmethod
     def connect_sessionless(self) -> None:
-        pass
+        if not self.tloop.is_alive():
+            self.tloop = ThreadLoop()
+            self.tloop.start()
+            self.close_tloop = True
+        self.tloop.post(self.aio_obj.connect_sessionless())
 
     def disconnect_sessionless(self) -> None:
         try:
@@ -274,9 +277,12 @@ def disconnect_sessionless(self) -> None:
             if self.close_tloop:
                 self.tloop.stop()
 
-    @syncmethod
     def connect_socket(self) -> None:
-        pass
+        if not self.tloop.is_alive():
+            self.tloop = ThreadLoop()
+            self.tloop.start()
+            self.close_tloop = True
+        self.tloop.post(self.aio_obj.connect_sessionless())
 
     def disconnect_socket(self) -> None:
         try: