Function readStreamingResponseBlob

src/utils/zipDownload.ts:71–98

(
  body: ReadableStream<Uint8Array>,
  total: number,
  onProgress: ZipProgressCallback
)

}

async function readStreamingResponseBlob(
  body: ReadableStream<Uint8Array>,
  total: number,
  onProgress: ZipProgressCallback
): Promise<Blob> {
  const reader = body.getReader();
  const chunks: Uint8Array[] = [];
  let loaded = 0;

  while (true) {
    const { done, value } = await reader.read();
    if (done) break;

    chunks.push(new Uint8Array(value));
    loaded += value.length;
    onProgress(getDownloadProgress(loaded, total));
  }

  const totalLength = chunks.reduce((sum, chunk) => sum + chunk.length, 0);
  const result = new Uint8Array(totalLength);
  let offset = 0;
  for (const chunk of chunks) {
    result.set(chunk, offset);
    offset += chunk.length;
  }

  return new Blob([result]);
}

function getDownloadProgress(loaded: number, total: number): ZipProgress {
  if (total > 0) {