Function createDelayedStream

e2e/solid-start/basic/src/raw-stream-fns.ts:4–17

(
  chunks: Array<Uint8Array>,
  delayMs: number,
)

// Helper to create a delayed Uint8Array stream
function createDelayedStream(
  chunks: Array<Uint8Array>,
  delayMs: number,
): ReadableStream<Uint8Array> {
  return new ReadableStream<Uint8Array>({
    async start(controller) {
      for (const chunk of chunks) {
        await new Promise((resolve) => setTimeout(resolve, delayMs))
        controller.enqueue(chunk)
      }
      controller.close()
    },
  })
}

// Helper to create a stream with variable delays per chunk
// Each entry is [chunk, delayBeforeMs] - delay happens BEFORE enqueueing the chunk