librt_realtime_client_quickstart_connect_send_receive.py

1import asyncio
2from librt import RealtimeClient
3
4async def main():
5    # Initialize the client with your API key and configuration
6    client = RealtimeClient(
7        api_key="your-api-key",
8        url="wss://api.example.com/v1/realtime"
9    )
10
11    # Connect to the realtime server
12    await client.connect()
13
14    # Send a message to the server
15    await client.send({
16        "type": "message.create",
17        "message": {
18            "content": "Hello, world!"
19        }
20    })
21
22    # Listen for incoming events
23    async for event in client.events():
24        print(f"Received event: {event}")
25        if event["type"] == "message.created":
26            break
27
28    # Close the connection
29    await client.close()
30
31if __name__ == "__main__":
32    asyncio.run(main())