Streaming

GET /v2/stream keeps one HTTP connection open and sends each new trade and market move the moment it lands. Each frame has the same shape as a row from List Trades or List Moves. Rivo applies your filters before it sends anything, so you receive only what you asked for.

curl -N "https://api.rivo.markets/v2/stream?channels=trades&venue=kalshi&minWinRate=0.6" \
  -H "Authorization: Bearer $RIVO_API_KEY"

Frames#

One market, everything on it#

The market filter applies to both channels. Send ?market=<ref> to receive every trade and every move on one market over a single connection. Repeat market to watch up to 50 markets.

Reconnecting#

Connections drop when we deploy, when a network fails, or when a laptop goes to sleep. Save the time of the last frame you handled. When the connection drops, reconnect after a short backoff, then fetch the trades you missed from the list route with the same filters.

let lastSeen = new Date().toISOString();

async function fillGap(): Promise<void> {
  const res = await fetch(`https://api.rivo.markets/v2/trades?venue=kalshi&since=${lastSeen}&limit=200`, { headers });
  for (const trade of (await res.json()).data.reverse()) handle(trade);
}

// On every trade frame: lastSeen = trade.time
// After a reconnect: await fillGap(), then keep reading the stream.

Remove duplicates by id, because a trade that arrived just before the drop can appear again when you fetch the gap.

Limits#

• Each key can hold three streams open at once, including any on /v1/stream. The API refuses a fourth with 429 QUOTA_EXCEEDED.
• An open stream counts as one request a minute.
• Each trade the stream sends counts toward your 50,000 trades a day. Moves do not count.

The Stream reference lists every parameter and shows a full client in three languages.