export function getChunkedStream()

in test-utils/mock-response.ts [27:50]


export function getChunkedStream(
  input: string,
  chunkLength = 20,
): ReadableStream<Uint8Array> {
  const encoder = new TextEncoder();
  let currentChunkStart = 0;

  const stream = new ReadableStream<Uint8Array>({
    start(controller) {
      while (currentChunkStart < input.length) {
        const substring = input.slice(
          currentChunkStart,
          currentChunkStart + chunkLength,
        );
        currentChunkStart += chunkLength;
        const chunk = encoder.encode(substring);
        controller.enqueue(chunk);
      }
      controller.close();
    },
  });

  return stream;
}