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

Comparing version 0.7.6-alpha-20250107153812-2b7cc1f8c195a23bdaa804e863be3032890ab3c1 to 0.7.6-alpha-20250107210838-55d5cc33b082b1962ee6ef7a42c21f20e2767b1c

cjs/fetchCurl.js

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

esm/fetchCurl.js

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

package.json

 {
   "name": "@whatwg-node/node-fetch",
-  "version": "0.7.6-alpha-20250107153812-2b7cc1f8c195a23bdaa804e863be3032890ab3c1",
+  "version": "0.7.6-alpha-20250107210838-55d5cc33b082b1962ee6ef7a42c21f20e2767b1c",
   "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

Worsened metrics

Total package byte prevSize

222516

decreased by-0.13%

Lines of code

5635

decreased by-0.14%

No dependency changes