fix
This commit is contained in:
@@ -542,7 +542,8 @@ async def websocket_network_state(ws: WebSocket) -> None:
|
|||||||
|
|
||||||
queue: Optional[asyncio.Queue] = None
|
queue: Optional[asyncio.Queue] = None
|
||||||
try:
|
try:
|
||||||
await ws.send_json({"type": "network_state", "reason": "initial", "snapshot": build_full_state_payload()})
|
initial_snapshot = await asyncio.to_thread(build_full_state_payload)
|
||||||
|
await ws.send_json({"type": "network_state", "reason": "initial", "snapshot": initial_snapshot})
|
||||||
queue = await broadcaster.subscribe()
|
queue = await broadcaster.subscribe()
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
|
|||||||
Reference in New Issue
Block a user