Skip to main content

LiveEventSource

@forge/monorepo


@forge/monorepo / backend/src / LiveEventSource

Interface: LiveEventSource

Defined in: backend/src/runtime/streaming.ts:30

Live fan-in half of reconnect. subscribe must begin buffering at call time so the catch-up read cannot race ahead of live events. Adapters: the in-memory bus below, Supabase Realtime, Redis.

Methods

subscribe()

subscribe(channel): AsyncIterable<RunEvent>

Defined in: backend/src/runtime/streaming.ts:31

Parameters

channel

string

Returns

AsyncIterable<RunEvent>