Function createStreamConsumer

e2e/solid-start/basic/src/raw-stream-fns.ts:371–394

()

// but after SSR deserialization it becomes ReadableStream<Uint8Array>.
// We accept both types to handle the TypeScript mismatch.
export function createStreamConsumer() {
  const decoder = new TextDecoder()

  return async function consumeStream(
    stream: ReadableStream<Uint8Array> | RawStream,
  ): Promise<string> {
    // Handle both RawStream (from type system) and ReadableStream (runtime)
    const actualStream =
      stream instanceof RawStream
        ? stream.stream
        : (stream as ReadableStream<Uint8Array>)
    const reader = actualStream.getReader()
    const chunks: Array<string> = []

    // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
    while (true) {
      const { done, value } = await reader.read()
      if (done) break
      chunks.push(decoder.decode(value, { stream: true }))
    }

    return chunks.join('')
  }
}

export async function consumeBinaryStream(
  stream: ReadableStream<Uint8Array> | RawStream,