@hono/node-server - npm Package Compare versions

Comparing version 1.19.4 to 1.19.5

dist/index.js

@@ -305,8 +305,12 @@ "use strict";
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -313,0 +317,0 @@ function handleStreamError(error) {

dist/index.mjs

@@ -266,8 +266,12 @@ // src/server.ts
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -274,0 +278,0 @@ function handleStreamError(error) {

dist/listener.js

@@ -297,8 +297,12 @@ "use strict";
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -305,0 +309,0 @@ function handleStreamError(error) {

dist/listener.mjs

@@ -263,8 +263,12 @@ // src/listener.ts
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -271,0 +275,0 @@ function handleStreamError(error) {

dist/server.js

@@ -301,8 +301,12 @@ "use strict";
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -309,0 +313,0 @@ function handleStreamError(error) {

dist/server.mjs

@@ -266,8 +266,12 @@ // src/server.ts
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -274,0 +278,0 @@ function handleStreamError(error) {

dist/utils.js

@@ -33,8 +33,12 @@ "use strict";
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -41,0 +45,0 @@ function handleStreamError(error) {

dist/utils.mjs

@@ -6,8 +6,12 @@ // src/utils.ts
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -14,0 +18,0 @@ function handleStreamError(error) {

dist/vercel.js

@@ -299,8 +299,12 @@ "use strict";
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -307,0 +311,0 @@ function handleStreamError(error) {

dist/vercel.mjs

@@ -263,8 +263,12 @@ // src/listener.ts
 function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
-  const handleError = () => {
+  const cancel = (error) => {
+    reader.cancel(error).catch(() => {
+    });
   };
-  writable.on("error", handleError);
+  writable.on("close", cancel);
+  writable.on("error", cancel);
   (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
   return reader.closed.finally(() => {
-    writable.off("error", handleError);
+    writable.off("close", cancel);
+    writable.off("error", cancel);
   });
@@ -271,0 +275,0 @@ function handleStreamError(error) {

package.json

 {
   "name": "@hono/node-server",
-  "version": "1.19.4",
+  "version": "1.19.5",
   "description": "Node.js Adapter for Hono",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

New alerts

Network access

Supply chain risk

This module accesses the network.

Found 3 instances in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 3 instances in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

205020

0.51%

Lines of code

6047

0.67%

No dependency changes