Merge pull request #66 from uaarg/emu-server

Emu server works better with images

Author: kaiden-keane

samples/emu_connection.py

@@ -29,10 +29,10 @@
     elif i % 3 == 1: severity = "warning"
     else: severity = "error"
     emu.send_log(f"log text {i}", severity)
-    time.sleep(0.5)
+    time.sleep(1)
 
-# send new photo
-print("sending image")
-emu.send_image("test-image.jpeg")
-
-time.sleep(500)
+while True:
+    print("sending image")
+    emu.send_log("sending image")
+    emu.send_image("test-image.jpeg")
+    time.sleep(2)

src/modules/emu/emu.py

@@ -81,8 +81,9 @@ async def producer_handler(self, ws):
         """
         handles sending messages to the client
         """
+        event_loop = asyncio.get_running_loop()
         while not ws.closed:
-            message = self._send_queue.get()
+            message = await event_loop.run_in_executor(None, self._send_queue.get)
             await ws.send_str(message)
 
     async def handle_websocket(self, request):
@@ -103,8 +104,3 @@ async def handle_websocket(self, request):
         producer_task.cancel()
 
         return ws
-
-if __name__ == "__main__":
-    emu = Emu("tmp/imgs")
-    emu.start_comms()
-    while (1): pass