test: update test

Author: pi0

test/app.test.ts

@@ -1,4 +1,7 @@
-import { Readable } from "node:stream";
+import {
+  Readable as NodeStreamReadable,
+  Transform as NodeStreamTransoform,
+} from "node:stream";
 import { HTTPError, fromNodeHandler } from "../src/index.ts";
 import { describeMatrix } from "./_setup.ts";
 
@@ -101,7 +104,7 @@ describeMatrix("app", (t, { it, expect }) => {
 
   it.runIf(t.target === "node")("Node.js Readable Stream", async () => {
     t.app.use(() => {
-      return new Readable({
+      return new NodeStreamReadable({
         read() {
           this.push(Buffer.from("<h1>Hello world!</h1>", "utf8"));
           this.push(null);
@@ -115,33 +118,32 @@ describeMatrix("app", (t, { it, expect }) => {
   });
 
   // TODO: investigate issues with stream errors on srvx
-  // it.runIf(t.target === "node")(
-  //   "Node.js Readable Stream with Error",
-  //   async () => {
-  //     t.app.use(() => {
-  //       return new Readable({
-  //         read() {
-  //           this.push(Buffer.from("123", "utf8"));
-  //           this.push(null);
-  //         },
-  //       }).pipe(
-  //         new Transform({
-  //           transform(_chunk, _encoding, callback) {
-  //             const err = createError({
-  //               statusCode: 500,
-  //               statusText: "test",
-  //             });
-  //             setTimeout(() => callback(err), 0);
-  //           },
-  //         }),
-  //       );
-  //     });
-  //     // const res = await t.fetch("/");
-  //     expect(async () => await t.fetch("/")).toThrowError();
-  //     // expect(res.status).toBe(500);
-  //     // expect(JSON.parse(await res.text()).statusMessage).toBe("test");
-  //   },
-  // );
+  it.runIf(/* t.target === "node" */ false)(
+    "Node.js Readable Stream with Error",
+    async () => {
+      t.app.use(() => {
+        return new NodeStreamReadable({
+          read() {
+            this.push(Buffer.from("123", "utf8"));
+            this.push(null);
+          },
+        }).pipe(
+          new NodeStreamTransoform({
+            transform(_chunk, _encoding, callback) {
+              const err = new HTTPError({
+                statusCode: 500,
+                statusText: "test",
+              });
+              setTimeout(() => callback(err), 0);
+            },
+          }),
+        );
+      });
+      const res = await t.fetch("/");
+      expect(res.status).toBe(500);
+      expect(JSON.parse(await res.text()).statusMessage).toBe("test");
+    },
+  );
 
   it("Web Stream", async () => {
     t.app.use(() => {
@@ -156,7 +158,10 @@ describeMatrix("app", (t, { it, expect }) => {
     const res = await t.fetch("/");
 
     expect(await res.text()).toBe("<h1>Hello world!</h1>");
-    // expect(res.headers.get("transfer-encoding")).toBe("chunked"); // TODO: h3 should add this header
+    if (t.target === "node") {
+      // In Web API, we cannot determine protocol and connection type
+      expect(res.headers.get("transfer-encoding")).toBe("chunked");
+    }
   });
 
   it("Web Stream with Error", async () => {