Fetch

@rotorsoft/act-root

---

@rotorsoft/act-root / act/src / Fetch

Type Alias: Fetch<TEvents>

Fetch<TEvents> = object[]

Defined in: libs/act/src/types/reaction.ts:266

Result of fetching events from the store for processing.

Type Parameters

TEvents

TEvents extends Schemas

Event schemas.

Type Declaration

at

readonly at: number

error?

readonly optional error?: string

Why this stream's read failed, when it did. Present only on failure, and then events is empty.

Reads are per-stream but ran under one Promise.all, so a single stream's failure rejected the whole cycle and every healthy stream leased alongside it got nothing — a corrupt pii payload on one aggregate stalled unrelated reactions. Isolating the failure here keeps the blast radius on the stream that caused it: the cycle records the error, submits no ack (so the watermark holds), and the stream accrues retry until blockOnError quarantines it the usual way — visible in blocked_streams() instead of silent.

events

readonly events: Committed<TEvents, keyof TEvents>[]

lagging

readonly lagging: boolean

source?

readonly optional source?: string

stream

readonly stream: string