broadcaster

import asyncio import os from broadcaster import Broadcaster BROADCAST_URL = os.environ.get("BROADCAST_URL", "memory://") async def main(): # Initialize broadcaster with a URL, defaults to in-memory if env var is not set broadcaster = Broadcaster(BROADCAST_URL) # Establish connection to the backend await broadcaster.connect() async with broadcaster.subscribe("chat") as subscriber: # Publish a message await broadcaster.publish("chat", "Hello from broadcaster!") print(f"Published: Hello from broadcaster!") # Receive a message message = await subscriber.get() print(f"Received: {message}") # Disconnect from the backend await broadcaster.disconnect() if __name__ == "__main__": asyncio.run(main())