Live stream

curl -N "https://api.rivo.markets/v1/stream?lane=tracked" \
  -H "Authorization: Bearer rivo_live_..."

import json
import httpx

url = "https://api.rivo.markets/v1/stream"
headers = {"Authorization": "Bearer rivo_live_..."}

# stream=True, and never call .json(): the body does not end.
with httpx.stream("GET", url, headers=headers, params={"lane": "tracked"}, timeout=None) as r:
    r.raise_for_status()
    for line in r.iter_lines():
        if line.startswith(":"):      # ": connected" / ": ping" keepalives
            continue
        if line.startswith("data: "):
            trade = json.loads(line[6:])
            print(trade["marketTitle"], trade["amount"])

// EventSource cannot set headers, so it takes the key in the query string.
// Prefer the fetch form below wherever your runtime allows it.
const es = new EventSource(
  "https://api.rivo.markets/v1/stream?lane=tracked&key=rivo_live_...",
);

es.onmessage = (e) => {
  const trade = JSON.parse(e.data);
  console.log(trade.marketTitle, trade.amount);
};
es.onerror = () => {
  // The browser reconnects on its own. There is no replay: backfill any gap
  // from /v1/feed with a cursor.
};

// Server-side, keep the key in a header instead:
const res = await fetch("https://api.rivo.markets/v1/stream?lane=tracked", {
  headers: { Authorization: "Bearer rivo_live_..." },
});
const reader = res.body!.pipeThrough(new TextDecoderStream()).getReader();
for (;;) {
  const { value, done } = await reader.read();
  if (done) break;
  for (const line of (value ?? "").split("\n")) {
    if (line.startsWith("data: ")) console.log(JSON.parse(line.slice(6)));
  }
}