From ca0127c480d9601e20324bfc3dab34e4326a9739 Mon Sep 17 00:00:00 2001 From: Edward Li Date: Sun, 2 Oct 2022 04:05:02 -0400 Subject: [PATCH] bridge fixses --- zmq_websocket_bridge.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/zmq_websocket_bridge.py b/zmq_websocket_bridge.py index faf44ce..544da33 100644 --- 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)