Highest (latest) location observed so far; undefined until first object
Register a listener invoked when the live stream ends (normal or error). Returns an unsubscribe function.
Register a listener invoked (async) for each new object. Returns an unsubscribe function.
Stop ingestion and release underlying reader (idempotent).
Push-oriented live object feed. Wraps a ReadableStream plus lightweight event subscription helpers. Implementations advance largestLocation monotonically as objects arrive.