Merge pull request #279 from DoubleData/feature/respect-abort-signal

Clear abort listener

Author: mindhells

spec/index.spec.ts

@@ -382,6 +382,34 @@ describe('axiosRetry(axios, { retries, retryCondition })', () => {
           setTimeout(() => abortController.abort(), 50);
           const timeStart = new Date().getTime();
         });
+
+        it('should cancel old requests', (done) => {
+          const client = axios.create();
+          setupResponses(client, [
+            () => nock('http://example.com').get('/test').delay(100).reply(429),
+            () => nock('http://example.com').get('/test').delay(100).reply(429),
+            () => nock('http://example.com').get('/test').delay(100).reply(429)
+          ]);
+          axiosRetry(client, {
+            retries: 2,
+            retryCondition: () => true,
+            retryDelay: () => 0
+          });
+          const abortController = new AbortController();
+          client
+            .get('http://example.com/test', { signal: abortController.signal })
+            .then(
+              () => done.fail(),
+              (error) => {
+                expect(error).toBeInstanceOf(CanceledError);
+                expect(new Date().getTime() - timeStart).toBeLessThan(300);
+                done();
+              }
+            )
+            .catch(done.fail);
+          setTimeout(() => abortController.abort(), 250);
+          const timeStart = new Date().getTime();
+        });
       });
     });
 

src/index.ts

@@ -255,17 +255,19 @@ async function handleRetry(
   if (config.signal?.aborted) {
     return Promise.resolve(axiosInstance(config));
   }
-  return new Promise((resolve, reject) => {
-    const timeout = setTimeout(() => resolve(axiosInstance(config)), delay);
+  return new Promise((resolve) => {
+    const abortListener = () => {
+      clearTimeout(timeout);
+      resolve(axiosInstance(config));
+    };
+    const timeout = setTimeout(() => {
+      resolve(axiosInstance(config));
+      if (config.signal?.removeEventListener) {
+        config.signal.removeEventListener('abort', abortListener);
+      }
+    }, delay);
     if (config.signal?.addEventListener) {
-      config.signal.addEventListener(
-        'abort',
-        () => {
-          clearTimeout(timeout);
-          resolve(axiosInstance(config));
-        },
-        { once: true }
-      );
+      config.signal.addEventListener('abort', abortListener, { once: true });
     }
   });
 }