Stream many events

for ev in events[:20]:
    ws.send(json.dumps(["register_event", ev["sport"], ev["event_id"]]))

ws.send(json.dumps(["unregister_event", sport, event_id]))
ws.send(json.dumps(["list_registered_events"]))     # what the server thinks you hold

import queue, threading

frames = queue.Queue(maxsize=10000)

def reader(ws):
    while True:
        frames.put(ws.recv())

def worker():
    while True:
        for entry in json.loads(frames.get())["data"]:
            handle(entry)

threading.Thread(target=reader, args=(ws,), daemon=True).start()
threading.Thread(target=worker, daemon=True).start()

import time
from websockets.sync.client import connect

registered = set()      # (sport, event_id)
delay = 1
while True:
    try:
        with connect(url) as ws:
            delay = 1
            events = resync(ws)                  # collect until sync
            for sport, event_id in registered:
                ws.send(json.dumps(["register_event", sport, event_id]))
            pump(ws)
    except Exception as e:
        print("reconnecting after", e)
        time.sleep(delay)
        delay = min(delay * 2, 60)