Function streamFromChunks

apps/sim/lib/core/utils/stream-limits.test.ts:19–31

(chunks: Uint8Array[])

} from '@/lib/core/utils/stream-limits'

function streamFromChunks(chunks: Uint8Array[]): ReadableStream<Uint8Array> {
  let index = 0
  return new ReadableStream({
    pull(controller) {
      if (index >= chunks.length) {
        controller.close()
        return
      }
      controller.enqueue(chunks[index])
      index += 1
    },
  })
}

function headers(contentLength?: string): Headers {
  const headers = new Headers()