feat: add progressUpdateIntervalMs config option;

README.md

@@ -529,6 +529,10 @@ These are the available config options for making requests. Only the `url` is re
     // Do whatever you want with the Axios progress event
   },
 
+  // `progressUpdateIntervalMs` controls the frequency in milliseconds of download and upload progress events
+  // browser & node.js
+  progressUpdateIntervalMs: 100
+
   // `maxContentLength` defines the max size of the http response content in bytes allowed in node.js
   maxContentLength: 2000,
 

dist/browser/axios.cjs

@@ -2530,14 +2530,19 @@ var xhrAdapter = isXHRAdapterSupported && function (config) {
       request.responseType = _config.responseType;
     }
 
+    let progressUpdateTicksRate = undefined;
+    if (utils$1.isNumber(config.progressUpdateIntervalMs)) {
+      progressUpdateTicksRate = 1000 / config.progressUpdateIntervalMs;
+    }
+
     // Handle progress if needed
     if (typeof _config.onDownloadProgress === 'function') {
-      request.addEventListener('progress', progressEventReducer(_config.onDownloadProgress, true));
+      request.addEventListener('progress', progressEventReducer(_config.onDownloadProgress, true, progressUpdateTicksRate));
     }
 
     // Not all browsers support upload events
     if (typeof _config.onUploadProgress === 'function' && request.upload) {
-      request.upload.addEventListener('progress', progressEventReducer(_config.onUploadProgress));
+      request.upload.addEventListener('progress', progressEventReducer(_config.onUploadProgress, progressUpdateTicksRate));
     }
 
     if (_config.cancelToken || _config.signal) {
@@ -2781,6 +2786,11 @@ var fetchAdapter = isFetchSupported && (async (config) => {
   };
 
   try {
+    let progressUpdateTicksRate = undefined;
+    if (utils$1.isNumber(config.progressUpdateIntervalMs)) {
+      progressUpdateTicksRate = 1000 / config.progressUpdateIntervalMs;
+    }
+
     if (onUploadProgress && supportsRequestStream && method !== 'get' && method !== 'head') {
       let requestContentLength = await resolveBodyLength(headers, data);
 
@@ -2798,7 +2808,7 @@ var fetchAdapter = isFetchSupported && (async (config) => {
 
       data = trackStream(_request.body, DEFAULT_CHUNK_SIZE, fetchProgressDecorator(
         requestContentLength,
-        progressEventReducer(onUploadProgress)
+        progressEventReducer(onUploadProgress, false, progressUpdateTicksRate)
       ));
     }
 
@@ -2832,7 +2842,7 @@ var fetchAdapter = isFetchSupported && (async (config) => {
       response = new Response(
         trackStream(response.body, DEFAULT_CHUNK_SIZE, onDownloadProgress && fetchProgressDecorator(
           responseContentLength,
-          progressEventReducer(onDownloadProgress, true)
+          progressEventReducer(onDownloadProgress, true, progressUpdateTicksRate)
         ), isStreamResponse && onFinish),
         options
       );

dist/node/axios.cjs

@@ -2835,6 +2835,11 @@ const httpAdapter = isHttpAdapterSupported && function httpAdapter(config) {
 
     const contentLength = utils$1.toFiniteNumber(headers.getContentLength());
 
+    let progressUpdateTicksRate = undefined;
+    if (utils$1.isNumber(config.progressUpdateIntervalMs)) {
+      progressUpdateTicksRate = 1000 / config.progressUpdateIntervalMs;
+    }
+
     if (utils$1.isArray(maxRate)) {
       maxUploadRate = maxRate[0];
       maxDownloadRate = maxRate[1];
@@ -2849,7 +2854,8 @@ const httpAdapter = isHttpAdapterSupported && function httpAdapter(config) {
 
       data = stream__default["default"].pipeline([data, new AxiosTransformStream$1({
         length: contentLength,
-        maxRate: utils$1.toFiniteNumber(maxUploadRate)
+        maxRate: utils$1.toFiniteNumber(maxUploadRate),
+        ticksRate: progressUpdateTicksRate,
       })], utils$1.noop);
 
       onUploadProgress && data.on('progress', progress => {
@@ -2958,7 +2964,8 @@ const httpAdapter = isHttpAdapterSupported && function httpAdapter(config) {
       if (onDownloadProgress) {
         const transformStream = new AxiosTransformStream$1({
           length: utils$1.toFiniteNumber(responseLength),
-          maxRate: utils$1.toFiniteNumber(maxDownloadRate)
+          maxRate: utils$1.toFiniteNumber(maxDownloadRate),
+          ticksRate: progressUpdateTicksRate,
         });
 
         onDownloadProgress && transformStream.on('progress', progress => {
@@ -3599,14 +3606,19 @@ const xhrAdapter = isXHRAdapterSupported && function (config) {
       request.responseType = _config.responseType;
     }
 
+    let progressUpdateTicksRate = undefined;
+    if (utils$1.isNumber(config.progressUpdateIntervalMs)) {
+      progressUpdateTicksRate = 1000 / config.progressUpdateIntervalMs;
+    }
+
     // Handle progress if needed
     if (typeof _config.onDownloadProgress === 'function') {
-      request.addEventListener('progress', progressEventReducer(_config.onDownloadProgress, true));
+      request.addEventListener('progress', progressEventReducer(_config.onDownloadProgress, true, progressUpdateTicksRate));
     }
 
     // Not all browsers support upload events
     if (typeof _config.onUploadProgress === 'function' && request.upload) {
-      request.upload.addEventListener('progress', progressEventReducer(_config.onUploadProgress));
+      request.upload.addEventListener('progress', progressEventReducer(_config.onUploadProgress, progressUpdateTicksRate));
     }
 
     if (_config.cancelToken || _config.signal) {
@@ -3850,6 +3862,11 @@ const fetchAdapter = isFetchSupported && (async (config) => {
   };
 
   try {
+    let progressUpdateTicksRate = undefined;
+    if (utils$1.isNumber(config.progressUpdateIntervalMs)) {
+      progressUpdateTicksRate = 1000 / config.progressUpdateIntervalMs;
+    }
+
     if (onUploadProgress && supportsRequestStream && method !== 'get' && method !== 'head') {
       let requestContentLength = await resolveBodyLength(headers, data);
 
@@ -3867,7 +3884,7 @@ const fetchAdapter = isFetchSupported && (async (config) => {
 
       data = trackStream(_request.body, DEFAULT_CHUNK_SIZE, fetchProgressDecorator(
         requestContentLength,
-        progressEventReducer(onUploadProgress)
+        progressEventReducer(onUploadProgress, false, progressUpdateTicksRate)
       ));
     }
 
@@ -3901,7 +3918,7 @@ const fetchAdapter = isFetchSupported && (async (config) => {
       response = new Response(
         trackStream(response.body, DEFAULT_CHUNK_SIZE, onDownloadProgress && fetchProgressDecorator(
           responseContentLength,
-          progressEventReducer(onDownloadProgress, true)
+          progressEventReducer(onDownloadProgress, true, progressUpdateTicksRate)
         ), isStreamResponse && onFinish),
         options
       );

index.d.cts

@@ -393,6 +393,7 @@ declare namespace axios {
     xsrfHeaderName?: string;
     onUploadProgress?: (progressEvent: AxiosProgressEvent) => void;
     onDownloadProgress?: (progressEvent: AxiosProgressEvent) => void;
+    progressUpdateIntervalMs?: number;
     maxContentLength?: number;
     validateStatus?: ((status: number) => boolean) | null;
     maxBodyLength?: number;

index.d.ts

@@ -334,6 +334,7 @@ export interface AxiosRequestConfig<D = any> {
   xsrfHeaderName?: string;
   onUploadProgress?: (progressEvent: AxiosProgressEvent) => void;
   onDownloadProgress?: (progressEvent: AxiosProgressEvent) => void;
+  progressUpdateIntervalMs?: number;
   maxContentLength?: number;
   validateStatus?: ((status: number) => boolean) | null;
   maxBodyLength?: number;

lib/adapters/fetch.js

@@ -118,6 +118,11 @@ export default isFetchSupported && (async (config) => {
   }
 
   try {
+    let progressUpdateTicksRate = undefined;
+    if (utils.isNumber(config.progressUpdateIntervalMs)) {
+      progressUpdateTicksRate = 1000 / config.progressUpdateIntervalMs;
+    }
+
     if (onUploadProgress && supportsRequestStream && method !== 'get' && method !== 'head') {
       let requestContentLength = await resolveBodyLength(headers, data);
 
@@ -135,7 +140,7 @@ export default isFetchSupported && (async (config) => {
 
       data = trackStream(_request.body, DEFAULT_CHUNK_SIZE, fetchProgressDecorator(
         requestContentLength,
-        progressEventReducer(onUploadProgress)
+        progressEventReducer(onUploadProgress, false, progressUpdateTicksRate)
       ));
     }
 
@@ -169,7 +174,7 @@ export default isFetchSupported && (async (config) => {
       response = new Response(
         trackStream(response.body, DEFAULT_CHUNK_SIZE, onDownloadProgress && fetchProgressDecorator(
           responseContentLength,
-          progressEventReducer(onDownloadProgress, true)
+          progressEventReducer(onDownloadProgress, true, progressUpdateTicksRate)
         ), isStreamResponse && onFinish),
         options
       );