Function readSSEEvents

apps/sim/lib/core/utils/sse.ts:179–197

(
  source: SSESource,
  options: ReadSSEEventsOptions<T>
)

 * @param options - The `onEvent` callback plus optional `signal`/`onParseError`.
 */
export async function readSSEEvents<T = unknown>(
  source: SSESource,
  options: ReadSSEEventsOptions<T>
): Promise<void> {
  const { onEvent, onParseError, signal } = options
  await readSSELines(source, {
    signal,
    onData: (data) => {
      let parsed: T
      try {
        parsed = JSON.parse(data) as T
      } catch (error) {
        onParseError?.(data, error)
        return
      }
      return onEvent(parsed)
    },
  })
}

/**
 * Options for reading SSE stream