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

Comparing version 0.7.6-alpha-20250107153245-67dca693f97cb0bf5b4799924f9dde8537394b60 to 0.7.6-alpha-20250107153812-2b7cc1f8c195a23bdaa804e863be3032890ab3c1

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-20250107153245-67dca693f97cb0bf5b4799924f9dde8537394b60",
+  "version": "0.7.6-alpha-20250107153812-2b7cc1f8c195a23bdaa804e863be3032890ab3c1",
   "description": "Fetch API implementation for Node",
@@ -5,0 +5,0 @@ "sideEffects": false,

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

222808

increased by0.13%

Lines of code

5643

increased by0.14%

No dependency changes