Port another test from internal streams tests

Author: jasnell

src/workerd/api/tests/BUILD.bazel

@@ -737,3 +737,9 @@ wd_test(
     args = ["--experimental"],
     data = ["identity-transform-stream-state-machine-test.js"],
 )
+
+wd_test(
+    src = "response-used-body-test.wd-test",
+    args = ["--experimental"],
+    data = ["response-used-body-test.js"],
+)

src/workerd/api/tests/response-used-body-test.js

@@ -0,0 +1,25 @@
+import { rejects } from 'assert';
+
+// Ported from the internal respond.ew-test
+
+export const abortInternalStreamsTest = {
+  async test(_, env) {
+    await rejects(env.subrequest.fetch('http://example.org'), {
+      message: /Body has already been used/,
+    });
+  },
+};
+
+export default {
+  async fetch() {
+    const enc = new TextEncoder();
+    const rs = new ReadableStream({
+      pull(c) {
+        c.enqueue(enc.encode('hello'));
+      },
+    });
+    const response = new Response(rs);
+    rs.cancel(new Error('boom'));
+    return response;
+  },
+};

src/workerd/api/tests/response-used-body-test.wd-test

@@ -0,0 +1,17 @@
+using Workerd = import "/workerd/workerd.capnp";
+
+const unitTests :Workerd.Config = (
+  services = [
+    ( name = "response-used-body-test",
+      worker = (
+        modules = [
+          (name = "worker", esModule = embed "response-used-body-test.js")
+        ],
+        compatibilityFlags = ["nodejs_compat_v2", "streams_enable_constructors"],
+        bindings = [
+          (name = "subrequest", service = "response-used-body-test")
+        ]
+      )
+    ),
+  ],
+);