Function replayStream

demo/chat/stream-replay.ts:34–50

(
  text: string,
  onChunk: (chunk: string) => void,
  options: ReplayOptions,
)

/** Replay saved HTML text chunk-by-chunk like a live API stream. */
export async function replayStream(
  text: string,
  onChunk: (chunk: string) => void,
  options: ReplayOptions,
): Promise<void> {
  let index = 0;
  while (index < text.length) {
    if (options.signal?.aborted) {
      throw new DOMException("Aborted", "AbortError");
    }
    const size = nextChunkSize(text, index, options.chunkSize);
    const chunk = text.slice(index, index + size);
    index += size;
    onChunk(chunk);
    await sleep(options.delayMs, options.signal);
  }
}