Fix ReadableStream.pipeTo() being unimplemented in the web runtime (#…

…32602)

Currently we are using a TransformStream to process the forwarded stream for the inlined data, but unfortunately the `pipeTo` method is not implemented in the web runtime. This PR changes it to a naive way of doing so.

## Bug

- [ ] Related issues linked using `fixes #number`
- [ ] Integration tests added
- [ ] Errors have helpful link attached, see `contributing.md`

## Feature

- [ ] Implements an existing feature request or RFC. Make sure the feature request has been accepted for implementation before opening a PR.
- [ ] Related issues linked using `fixes #number`
- [ ] Integration tests added
- [ ] Documentation added
- [ ] Telemetry added. In case of a feature if it's used or not.
- [ ] Errors have helpful link attached, see `contributing.md`

## Documentation / Examples

- [ ] Make sure the linting passes by running `yarn lint`

packages/next/build/webpack/loaders/next-middleware-ssr-loader/render.ts

@@ -101,6 +101,10 @@ export function getRender({
         renderOpts
       )
     } catch (err: any) {
+      console.error(
+        'An error occurred while rendering the initial result:',
+        err
+      )
       const errorRes = { statusCode: 500, err }
       try {
         result = await renderToHTML(

packages/next/server/render.tsx

@@ -298,28 +298,35 @@ function createRSCHook() {
       entry = createFromReadableStream(renderStream)
       rscCache.set(id, entry)
 
-      const transfomer = new TransformStream({
-        start(controller) {
-          if (bootstrap) {
-            controller.enqueue(
+      let bootstrapped = false
+      const forwardReader = forwardStream.getReader()
+      const writer = writable.getWriter()
+      function process() {
+        forwardReader.read().then(({ done, value }) => {
+          if (bootstrap && !bootstrapped) {
+            bootstrapped = true
+            writer.write(
               `<script>(self.__next_s=self.__next_s||[]).push(${JSON.stringify([
                 0,
                 id,
               ])})</script>`
             )
           }
-        },
-        transform(chunk, controller) {
-          controller.enqueue(
-            `<script>(self.__next_s=self.__next_s||[]).push(${JSON.stringify([
-              1,
-              id,
-              decoder.decode(chunk),
-            ])})</script>`
-          )
-        },
-      })
-      forwardStream.pipeThrough(transfomer).pipeTo(writable)
+          if (done) {
+            writer.close()
+          } else {
+            writer.write(
+              `<script>(self.__next_s=self.__next_s||[]).push(${JSON.stringify([
+                1,
+                id,
+                decoder.decode(value),
+              ])})</script>`
+            )
+            process()
+          }
+        })
+      }
+      process()
     }
     return entry
   }