Skip to content

Commit 44b611b

Browse files
committed
fix event queue
1 parent 4f94f7a commit 44b611b

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

sinric/_sinricpro.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -53,14 +53,14 @@ async def connect(self, udp_client=None, sleep=0):
5353
self.connection = await self.socket.connect()
5454
receive_message_task = asyncio.create_task(self.socket.receiveMessage(connection=self.connection))
5555
handle_queue_task = asyncio.create_task(self.socket.handleQueue())
56-
57-
await receive_message_task
58-
await handle_queue_task
59-
56+
6057
if self.event_callbacks is not None:
6158
handle_event_queue_task = asyncio.create_task(self.event_callbacks())
6259
await handle_event_queue_task
63-
60+
61+
await handle_queue_task
62+
await receive_message_task
63+
6464
except KeyboardInterrupt:
6565
self.logger.error('Keyboard interrupt')
6666
except Exception as e:

0 commit comments

Comments
 (0)