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;
}