QueryStreamsResult

@rotorsoft/act-root

---

@rotorsoft/act-root / act/src / QueryStreamsResult

Type Alias: QueryStreamsResult

QueryStreamsResult = object

Defined in: libs/act/src/types/ports.ts:303

Result of a Store.query_streams call.

Properties

count

readonly count: number

Defined in: libs/act/src/types/ports.ts:305

Number of stream positions delivered to the callback.

---

maxEventId

readonly maxEventId: number

Defined in: libs/act/src/types/ports.ts:304

Highest event id in the store (-1 when empty). An upper bound on how far any subscription could be behind — not a lag measurement. A subscription's watermark advances only over events that resolve to it, so a reader handling a subset of a state's events sits permanently below this with nothing pending. For "does this subscription have work waiting?", compare its at against its own correlated_at (see StreamPosition.correlated_at); fall back to this only for a row that carries no mark yet.