We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ba71df9 commit 9c7ed38Copy full SHA for 9c7ed38
tiled/server/streaming.py
@@ -501,17 +501,14 @@ async def live_sequence_source():
501
await pubsub.subscribe(f"notify:{node_id}")
502
503
async def live_iter():
504
- print(f"Live iterator started for node {node_id}")
505
async for message in pubsub.listen():
506
if message.get("type") == "message":
507
- print(f"Received live message for node {node_id}: {message}")
508
try:
509
yield int(message["data"])
510
except Exception as e:
511
logger.exception(f"Error parsing live message: {e}")
512
513
async def cleanup():
514
- print(f"Unsubscribing from Redis channel for node {node_id}")
515
await pubsub.unsubscribe(f"notify:{node_id}")
516
await pubsub.aclose()
517
0 commit comments