sem/5g_drone_ROS2
1
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

send messages async

Browse Source
This commit is contained in:
Sem van der Hoeven
2023-06-02 11:59:10 +02:00
parent 8ed216785c
commit f76943b36c
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/api_communication/api_communication/api_listener.py
View File

@@ -137,7 +137,7 @@ class ApiListener(Node):
while True: while True:
if len(self.message_queue) > 0 and self.websocket is not None and self.event_loop is not None: if len(self.message_queue) > 0 and self.websocket is not None and self.event_loop is not None:
# self.get_logger().info("sending message") # self.get_logger().info("sending message")
asyncio.ensure_future(self.publish_message(self.message_queue.pop(0)), loop=self.event_loop) asyncio.run(self.publish_message(self.message_queue.pop(0)))
def start_api_thread(self): def start_api_thread(self):
asyncio.run(self.handle_api()) asyncio.run(self.handle_api())