@whatwg-node/node-fetch - npm Package Compare versions

Comparing version 0.7.6-alpha-20250109001305-3002f5a56f2e1931522968b3d6eb544aa91559b6 to 0.7.6-alpha-20250109232708-2991d90eb21112e812c9058f8263208dd56c7280

cjs/fetchCurl.js

@@ -66,14 +66,15 @@ "use strict";
     let streamResolved;
-    if (fetchRequest['_signal']) {
-        fetchRequest['_signal'].onabort = () => {
-            if (curlHandle.isOpen) {
-                try {
-                    curlHandle.pause(CurlPause.Recv);
-                }
-                catch (e) {
-                    deferredPromise.reject(e);
-                }
+    function onAbort() {
+        if (curlHandle.isOpen) {
+            try {
+                curlHandle.pause(CurlPause.Recv);
             }
-        };
+            catch (e) {
+                deferredPromise.reject(e);
+            }
+        }
     }
+    if (fetchRequest['_signal']) {
+        fetchRequest['_signal'].addEventListener('abort', onAbort, { once: true });
+    }
     curlHandle.once('end', function endListener() {
@@ -86,2 +87,5 @@ try {
         }
+        if (fetchRequest['_signal']) {
+            fetchRequest['_signal'].removeEventListener('abort', onAbort);
+        }
     });
@@ -88,0 +92,0 @@ curlHandle.once('error', function errorListener(error) {

esm/fetchCurl.js

@@ -63,14 +63,15 @@ import { PassThrough, Readable } from 'node:stream';
     let streamResolved;
-    if (fetchRequest['_signal']) {
-        fetchRequest['_signal'].onabort = () => {
-            if (curlHandle.isOpen) {
-                try {
-                    curlHandle.pause(CurlPause.Recv);
-                }
-                catch (e) {
-                    deferredPromise.reject(e);
-                }
+    function onAbort() {
+        if (curlHandle.isOpen) {
+            try {
+                curlHandle.pause(CurlPause.Recv);
             }
-        };
+            catch (e) {
+                deferredPromise.reject(e);
+            }
+        }
     }
+    if (fetchRequest['_signal']) {
+        fetchRequest['_signal'].addEventListener('abort', onAbort, { once: true });
+    }
     curlHandle.once('end', function endListener() {
@@ -83,2 +84,5 @@ try {
         }
+        if (fetchRequest['_signal']) {
+            fetchRequest['_signal'].removeEventListener('abort', onAbort);
+        }
     });
@@ -85,0 +89,0 @@ curlHandle.once('error', function errorListener(error) {

package.json

 {
   "name": "@whatwg-node/node-fetch",
-  "version": "0.7.6-alpha-20250109001305-3002f5a56f2e1931522968b3d6eb544aa91559b6",
+  "version": "0.7.6-alpha-20250109232708-2991d90eb21112e812c9058f8263208dd56c7280",
   "description": "Fetch API implementation for Node",
@@ -5,0 +5,0 @@ "sideEffects": false,

No alert changes

Improved metrics

Total package byte prevSize

222808

increased by0.13%

Lines of code

5643

increased by0.14%

No dependency changes