openRunEventStream
@forge/monorepo / backend/src / openRunEventStream
Function: openRunEventStream()
openRunEventStream(
input):AsyncIterable<RunEvent>
Defined in: backend/src/runtime/streaming.ts:53
Ordered, gap-free, duplicate-free event stream from after. Subscribes first (so no live event
is lost during catch-up), replays the durable log, then follows live — skipping anything whose
sequence was already delivered. Ends on the run's terminal event or when signal aborts.
Parameters
input
after
number
channel
string
live
log
runId
signal?
{ aborted: boolean; }
signal.aborted
boolean
tenantId
Returns
AsyncIterable<RunEvent>