Consume request body in tests

test/e2e/cancel-request/app/edge-route/route.ts

@@ -5,7 +5,11 @@ export const runtime = 'edge'
 let streamable
 let requestAborted = false
 
-export function GET(req: Request): Response {
+export async function GET(req: Request): Promise<Response> {
+  // Consume the entire request body.
+  // This is so we don't confuse the request close with the connection close.
+  await req.text()
+
   // The 2nd request should render the stats. We don't use a query param
   // because edge rendering will create a different bundle for that.
   if (streamable) {

test/e2e/cancel-request/app/node-route/route.ts

@@ -7,7 +7,11 @@ export const dynamic = 'force-dynamic'
 let streamable
 let requestAborted = false
 
-export function GET(req: Request): Response {
+export async function GET(req: Request): Promise<Response> {
+  // Consume the entire request body.
+  // This is so we don't confuse the request close with the connection close.
+  await req.text()
+
   // The 2nd request should render the stats. We don't use a query param
   // because edge rendering will create a different bundle for that.
   if (streamable) {

test/e2e/cancel-request/middleware.ts

@@ -7,7 +7,11 @@ export const config = {
 let streamable
 let requestAborted = false
 
-export default function handler(req: Request): Response {
+export default async function handler(req: Request): Promise<Response> {
+  // Consume the entire request body.
+  // This is so we don't confuse the request close with the connection close.
+  await req.text()
+
   // The 2nd request should render the stats. We don't use a query param
   // because edge rendering will create a different bundle for that.
   if (streamable) {

test/e2e/cancel-request/pages/api/edge-api.ts

@@ -7,7 +7,11 @@ export const config = {
 let streamable
 let requestAborted = false
 
-export default function handler(req: Request): Response {
+export default async function handler(req: Request): Promise<Response> {
+  // Consume the entire request body.
+  // This is so we don't confuse the request close with the connection close.
+  await req.text()
+
   // The 2nd request should render the stats. We don't use a query param
   // because edge rendering will create a different bundle for that.
   if (streamable) {

test/e2e/cancel-request/pages/api/node-api.ts

@@ -13,6 +13,9 @@ export default function handler(
   _req: IncomingMessage,
   res: ServerResponse
 ): void {
+  // Pages API requests have already consumed the body.
+  // This is so we don't confuse the request close with the connection close.
+
   // The 2nd request should render the stats. We don't use a query param
   // because edge rendering will create a different bundle for that.
   if (readable) {