This API is in private preview. Target September 2026; timing is subject to change.
For the sequencing and recovery model, see timestamps, cursors, and replay.
- Persist the cursor after processing each message on a replay-capable stream.
- On disconnect, reconnect with exponential backoff and jitter.
- Resubscribe, supplying the last persisted cursor in each replay-capable subscription object. Complete-snapshot streams resubscribe without a cursor.
- Deduplicate overlapping messages using the identity documented for that stream — per-market sequence for book diffs, block height or round for block streams, and the event identity fields where a stream provides them.
- For stateful snapshot-and-diff streams, a message with
isSnapshot: truereplaces local state for that market.