From 6d235cd6beaa4695a137c195fc6d151bcea900f7 Mon Sep 17 00:00:00 2001 From: Janka Uryga Date: Fri, 19 Jun 2026 01:05:01 +0200 Subject: [PATCH] [Node Streams] Use node:stream/consumers --- packages/next/src/server/app-render/stream-ops.node.ts | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/packages/next/src/server/app-render/stream-ops.node.ts b/packages/next/src/server/app-render/stream-ops.node.ts index 0698da90df04..fc3a486d6abe 100644 --- a/packages/next/src/server/app-render/stream-ops.node.ts +++ b/packages/next/src/server/app-render/stream-ops.node.ts @@ -15,6 +15,7 @@ import { } from 'react-dom/server' import { prerender } from 'react-dom/static' import { PassThrough, Readable, Transform } from 'node:stream' +import * as StreamConsumers from 'node:stream/consumers' import { isUtf8 } from 'node:buffer' import { @@ -22,8 +23,6 @@ import { continueDynamicPrerender as webContinueDynamicPrerender, continueStaticFallbackPrerender as webContinueStaticFallbackPrerender, continueDynamicHTMLResume as webContinueDynamicHTMLResume, - streamToBuffer as webStreamToBuffer, - streamToString as webStreamToString, createDocumentClosingStream as webCreateDocumentClosingStream, createRuntimePrefetchTransformStream, CLOSE_TAG, @@ -888,11 +887,11 @@ export function chainStreams(...streams: AnyStream[]): AnyStream { } export async function streamToBuffer(stream: AnyStream): Promise { - return webStreamToBuffer(nodeReadableToWebReadableStream(stream)) + return StreamConsumers.buffer(stream) } export async function streamToString(stream: AnyStream): Promise { - return webStreamToString(nodeReadableToWebReadableStream(stream)) + return StreamConsumers.text(stream) } export function createWebInlinedDataStream(