import nats
import json

# Subscribe to a query
nc = await nats.connect("nats://localhost:4222")
res = await nc.request("livequery.orders.subscribe", json.dumps({
    "query": "SELECT * FROM orders WHERE status = 'pending'",
    "mode": "events"
}).encode())
data = json.loads(res.data)

# Receive real-time updates
async for msg in nc.subscribe(data["subject"]):
    print("Changes:", json.loads(msg.data)["events"])

// Subscribe to a query
nc, _ := nats.Connect("nats://localhost:4222")
res, _ := nc.Request("livequery.orders.subscribe", []byte(`{
  "query": "SELECT * FROM orders WHERE status = 'pending'",
  "mode": "events"
}`), time.Second*10)

var resp struct{ Subject string }
json.Unmarshal(res.Data, &resp)

// Receive real-time updates
nc.Subscribe(resp.Subject, func(msg *nats.Msg) {
    fmt.Println("Changes:", string(msg.Data))
})

// Subscribe to a query
let nc = async_nats::connect("nats://localhost:4222").await?;
let res = nc.request("livequery.orders.subscribe", r#"{
  "query": "SELECT * FROM orders WHERE status = 'pending'",
  "mode": "events"
}"#.into()).await?;

let data: serde_json::Value = serde_json::from_slice(&res.payload)?;

// Receive real-time updates
let mut sub = nc.subscribe(data["subject"].as_str().unwrap()).await?;
while let Some(msg) = sub.next().await {
    println!("Changes: {:?}", msg.payload);
}