chore(deps): replace on-finished with node:stream finished

package.json

@@ -38,7 +38,6 @@
     "@rspack/core": "2.2.9",
     "@types/express": "^5.0.6",
     "@types/node": "^24.19.2",
-    "@types/on-finished": "^2.3.5",
     "@types/range-parser": "^1.2.7",
     "connect-next": "^5.0.0",
     "cspell": "^10.3.6",
@@ -50,7 +49,6 @@
     "koa": "^3.2.1",
     "memfs": "4.80.0",
     "mrmime": "^2.0.1",
-    "on-finished": "^2.4.1",
     "range-parser": "^1.3.0",
     "router": "^2.2.0",
     "rstack": "^0.8.3",

src/middleware.js

@@ -1,7 +1,7 @@
 import path from "node:path";
+import { finished } from "node:stream";
 
 import { lookup, mimes } from "mrmime";
-import onFinishedStream from "on-finished";
 import rangeParser from "range-parser";
 
 import {
@@ -920,7 +920,7 @@ function wrapper(context) {
 
       if (outgoing) {
         // Response finished, cleanup
-        onFinishedStream(outgoing, cleanup);
+        finished(outgoing, cleanup);
       }
     }
 

test/middleware.test.js

@@ -1,6 +1,7 @@
 import fs from "node:fs";
 import { createServer } from "node:http";
 import path from "node:path";
+import { Readable } from "node:stream";
 
 import Hapi from "@hapi/hapi";
 import { serve } from "@hono/node-server";
@@ -3681,10 +3682,22 @@ describe.each([
         });
 
         it("should work with piping stream", async () => {
-          const response1 = await req.get("/file.text");
+          const stream = Readable.from(["text"], { autoDestroy: false });
+          const createReadStream = rs
+            .spyOn(instance.context.outputFileSystem, "createReadStream")
+            .mockReturnValue(stream);
 
-          expect(response1.statusCode).toBe(200);
-          expect(nextWasCalled).toBe(false);
+          try {
+            const response = await req.get("/file.text");
+
+            expect(response.statusCode).toBe(200);
+            expect(response.text).toBe("text");
+            expect(stream.destroyed).toBe(true);
+            expect(nextWasCalled).toBe(false);
+          } finally {
+            createReadStream.mockRestore();
+            stream.destroy();
+          }
         });
 
         it("should not allow to get files above root", async () => {