ITQC/pydase
24
0
Fork 0
mirror of https://github.com/tiqi-group/pydase.git synced 2025-06-08 14:30:41 +02:00
Code Issues Packages Projects Releases Wiki Activity

fixes client initialisation

Browse Source
This commit is contained in:
Mose Müller 2025-05-20 20:41:21 +02:00
parent 83c30439b6
commit cbd93fb166
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/pydase/client/client.py
View File

@ -134,8 +134,13 @@ class Client:
def connect(self, block_until_connected: bool = True) -> None: def connect(self, block_until_connected: bool = True) -> None:
if self._thread is None or self._loop is None: if self._thread is None or self._loop is None:
self._initialize_socketio_client()
self._loop = self._initialize_loop_and_thread() self._loop = self._initialize_loop_and_thread()
self._initialize_socketio_client()
self.proxy = ProxyClass(
sio_client=self._sio,
loop=self._loop,
reconnect=self.connect,
)
connection_future = asyncio.run_coroutine_threadsafe( connection_future = asyncio.run_coroutine_threadsafe(
self._connect(), self._loop self._connect(), self._loop
@ -163,11 +168,6 @@ class Client:
""" """
loop = asyncio.new_event_loop() loop = asyncio.new_event_loop()
self.proxy = ProxyClass(
sio_client=self._sio,
loop=loop,
reconnect=self.connect,
)
self._thread = threading.Thread( self._thread = threading.Thread(
target=asyncio_loop_thread, target=asyncio_loop_thread,
args=(loop,), args=(loop,),