Skip to content

EventLaneRuntime

Defined in: packages/client/src/event-lane.ts:185

abortInFlight: () => void

Defined in: packages/client/src/event-lane.ts:198

Abort any in-flight flush request (the teardown seam, mirroring the mutation runtime’s).

void


appendEvent: (stream, payload) => Promise<EventAppendResult>

Defined in: packages/client/src/event-lane.ts:188

string

unknown

Promise<EventAppendResult>


flush: () => Promise<void>

Defined in: packages/client/src/event-lane.ts:190

Drain the Outbox: assemble, POST and settle batches until nothing more is eligible this pass.

Promise<void>


readonly hasStreams: boolean

Defined in: packages/client/src/event-lane.ts:187

Whether the registry registered any Event stream. False → appendEvent throws and no driver is stood up.


onEventLaneReport: (listener) => () => void

Defined in: packages/client/src/event-lane.ts:196

Subscribe to per-flush reports. Ephemeral (nothing is retained); returns an unsubscribe.

(report) => void

() => void


onOutboxStatus: (listener) => () => void

Defined in: packages/client/src/event-lane.ts:194

Subscribe to the drain signal; the CURRENT state is delivered on subscribe. Returns an unsubscribe.

(status) => void

() => void


outboxStatus: () => Promise<OutboxStatus>

Defined in: packages/client/src/event-lane.ts:192

The current drain signal, read from the store.

Promise<OutboxStatus>