Function progressStream

native.ts:26–50

(parts: Uint8Array[])

const UPLOAD_CHUNK_SIZE = 262144; // 256 KB

function progressStream(parts: Uint8Array[]): ReadableStream<Uint8Array> {
    const total = parts.reduce((sum, part) => sum + part.length, 0);
    uploadProgress = { loaded: 0, total };
    let index = 0;
    let offset = 0;
    let loaded = 0;
    return new ReadableStream({
        pull(controller) {
            while (index < parts.length && offset >= parts[index].length) {
                index++;
                offset = 0;
            }
            if (index >= parts.length) {
                controller.close();
                return;
            }
            const part = parts[index];
            const end = Math.min(offset + UPLOAD_CHUNK_SIZE, part.length);
            controller.enqueue(part.subarray(offset, end));
            loaded += end - offset;
            offset = end;
            uploadProgress = { loaded, total };
        }
    });
}

function streamFetch(url: string, method: string, headers: Record<string, string>, parts: Uint8Array[], contentType?: string): Promise<Response> {
    const total = parts.reduce((sum, part) => sum + part.length, 0);