bridge fixses

GalenAI · Oct 2, 2022 · ca0127c · ca0127c
1 parent 3bfabfc
commit ca0127c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/zmq_websocket_bridge.py b/zmq_websocket_bridge.py
@@ -6,8 +6,11 @@ async def bridge(websocket):
     ctx = zmq.Context()
     socket = ctx.socket(zmq.SUB)
     socket.connect('ipc:///tmp/tabula')
+    socket.setsockopt(zmq.CONFLATE, 1)
     socket.subscribe('')
 
+    print("[INFO] Inited zmq...")
+
     while True:
         message = socket.recv()
         print(message)