Function pull

native.ts:33–48

(controller)

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