From b6a5a1888726180eb188be5e35b3f85bdba89146 Mon Sep 17 00:00:00 2001
From: wantaek <wantaekchoi@gmail.com>
Date: Mon, 27 Oct 2025 15:35:23 +0900
Subject: [PATCH 1/5] stream: add bytes() method to stream/consumers

- Add bytes() method to get Uint8Array from streams
- Add tests for bytes() method in PassThrough and ObjectMode scenarios
- Update documentation

Fixes: https://github.com/nodejs/node/issues/59542
---
 doc/api/webstreams.md                  | 35 ++++++++++++++++++++++++++
 lib/stream/consumers.js                | 10 ++++++++
 test/parallel/test-stream-consumers.js | 31 +++++++++++++++++++++++
 3 files changed, 76 insertions(+)

diff --git a/doc/api/webstreams.md b/doc/api/webstreams.md
index 5bc8734971aac1..f3e79a103f6e18 100644
--- a/doc/api/webstreams.md
+++ b/doc/api/webstreams.md
@@ -1694,6 +1694,41 @@ buffer(readable).then((data) => {
 });
 ```
 
+#### `streamConsumers.bytes(stream)`
+
+<!-- YAML
+added: v25.0.0
+-->
+
+* `stream` {ReadableStream|stream.Readable|AsyncIterator}
+* Returns: {Promise} Fulfills with a {Uint8Array} containing the full
+  contents of the stream.
+
+```mjs
+import { bytes } from 'node:stream/consumers';
+import { Readable } from 'node:stream';
+
+const dataBuffer = Buffer.from('hello world from consumers!');
+
+const readable = Readable.from(dataBuffer);
+const data = await bytes(readable);
+console.log(`from readable: ${data.length}`);
+// Prints: from readable: 27
+```
+
+```cjs
+const { bytes } = require('node:stream/consumers');
+const { Readable } = require('node:stream');
+
+const dataBuffer = Buffer.from('hello world from consumers!');
+
+const readable = Readable.from(dataBuffer);
+bytes(readable).then((data) => {
+  console.log(`from readable: ${data.length}`);
+  // Prints: from readable: 27
+});
+```
+
 #### `streamConsumers.json(stream)`
 
 <!-- YAML
diff --git a/lib/stream/consumers.js b/lib/stream/consumers.js
index 4566eff6a30f7f..f6c58056496bb4 100644
--- a/lib/stream/consumers.js
+++ b/lib/stream/consumers.js
@@ -2,6 +2,7 @@
 
 const {
   JSONParse,
+  Uint8Array,
 } = primordials;
 
 const {
@@ -50,6 +51,14 @@ async function buffer(stream) {
   return Buffer.from(await arrayBuffer(stream));
 }
 
+/**
+ * @param {AsyncIterable|ReadableStream|Readable} stream
+ * @returns {Promise<Uint8Array>}
+ */
+async function bytes(stream) {
+  return new Uint8Array(await buffer(stream));
+}
+
 /**
  * @param {AsyncIterable|ReadableStream|Readable} stream
  * @returns {Promise<string>}
@@ -82,6 +91,7 @@ module.exports = {
   arrayBuffer,
   blob,
   buffer,
+  bytes,
   text,
   json,
 };
diff --git a/test/parallel/test-stream-consumers.js b/test/parallel/test-stream-consumers.js
index 883d55dc6f02fb..118efce831bc0b 100644
--- a/test/parallel/test-stream-consumers.js
+++ b/test/parallel/test-stream-consumers.js
@@ -8,6 +8,7 @@ const {
   arrayBuffer,
   blob,
   buffer,
+  bytes,
   text,
   json,
 } = require('stream/consumers');
@@ -61,6 +62,18 @@ const kArrayBuffer =
   setTimeout(() => passthrough.end('there'), 10);
 }
 
+{
+  const passthrough = new PassThrough();
+
+  bytes(passthrough).then(common.mustCall(async (uint8arr) => {
+    assert(uint8arr instanceof Uint8Array);
+    assert.strictEqual(uint8arr.byteLength, 10);
+    assert.deepStrictEqual(Buffer.from(uint8arr), buf);
+  }));
+
+  passthrough.write('hello');
+  setTimeout(() => passthrough.end('there'), 10);
+}
 
 {
   const passthrough = new PassThrough();
@@ -219,6 +232,24 @@ const kArrayBuffer =
   stream.end({});
 }
 
+{
+  const stream = new PassThrough({
+    readableObjectMode: true,
+    writableObjectMode: true,
+  });
+
+  bytes(stream).then(common.mustCall((uint8arr) => {
+    assert(uint8arr instanceof Uint8Array);
+    assert.strictEqual(uint8arr.byteLength, 30);
+    assert.strictEqual(
+      Buffer.from(uint8arr).toString(),
+      '[object Object][object Object]');
+  }));
+
+  stream.write({});
+  stream.end({});
+}
+
 {
   const stream = new PassThrough({
     readableObjectMode: true,

From 79491e083c58b4b4fdb18fc259c5b31fab5381de Mon Sep 17 00:00:00 2001
From: wantaek <wantaekchoi@gmail.com>
Date: Fri, 31 Oct 2025 08:13:09 +0900
Subject: [PATCH 2/5] Use arrayBuffer() for direct Uint8Array conversion.
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: René <contact.9a5d6388@renegade334.me.uk>
---
 lib/stream/consumers.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/stream/consumers.js b/lib/stream/consumers.js
index f6c58056496bb4..a0d4a5d541ad66 100644
--- a/lib/stream/consumers.js
+++ b/lib/stream/consumers.js
@@ -56,7 +56,7 @@ async function buffer(stream) {
  * @returns {Promise<Uint8Array>}
  */
 async function bytes(stream) {
-  return new Uint8Array(await buffer(stream));
+  return new Uint8Array(await arrayBuffer(stream));
 }
 
 /**

From 2316bece134d5cceaf960b277bc92800730d7b7b Mon Sep 17 00:00:00 2001
From: wantaek <wantaekchoi@gmail.com>
Date: Tue, 4 Nov 2025 07:27:38 +0900
Subject: [PATCH 3/5] docs: add explicit Buffer import in bytes() examples

---
 doc/api/webstreams.md | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/doc/api/webstreams.md b/doc/api/webstreams.md
index f3e79a103f6e18..3a9c338173ca50 100644
--- a/doc/api/webstreams.md
+++ b/doc/api/webstreams.md
@@ -1707,6 +1707,7 @@ added: v25.0.0
 ```mjs
 import { bytes } from 'node:stream/consumers';
 import { Readable } from 'node:stream';
+import { Buffer } from 'node:buffer';
 
 const dataBuffer = Buffer.from('hello world from consumers!');
 
@@ -1719,6 +1720,7 @@ console.log(`from readable: ${data.length}`);
 ```cjs
 const { bytes } = require('node:stream/consumers');
 const { Readable } = require('node:stream');
+const { Buffer } = require('node:buffer');
 
 const dataBuffer = Buffer.from('hello world from consumers!');
 

From a2b7fe684e264970d10c4b75765558126c8602cf Mon Sep 17 00:00:00 2001
From: wantaek <wantaekchoi@gmail.com>
Date: Sat, 29 Nov 2025 09:16:32 +0900
Subject: [PATCH 4/5] Fix added version value

Co-authored-by: jakecastelli <38635403+jakecastelli@users.noreply.github.com>
---
 doc/api/webstreams.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/doc/api/webstreams.md b/doc/api/webstreams.md
index 3a9c338173ca50..6159511169a387 100644
--- a/doc/api/webstreams.md
+++ b/doc/api/webstreams.md
@@ -1697,7 +1697,7 @@ buffer(readable).then((data) => {
 #### `streamConsumers.bytes(stream)`
 
 <!-- YAML
-added: v25.0.0
+added: REPLACEME
 -->
 
 * `stream` {ReadableStream|stream.Readable|AsyncIterator}

From 2cad01035dbd868067affbe615221df5783ef5e2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ren=C3=A9?= <contact.9a5d6388@renegade334.me.uk>
Date: Wed, 28 Jan 2026 16:47:22 +0000
Subject: [PATCH 5/5] test: satisfy eslint

---
 test/parallel/test-stream-consumers.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/test/parallel/test-stream-consumers.js b/test/parallel/test-stream-consumers.js
index 118efce831bc0b..150808037252fa 100644
--- a/test/parallel/test-stream-consumers.js
+++ b/test/parallel/test-stream-consumers.js
@@ -65,7 +65,7 @@ const kArrayBuffer =
 {
   const passthrough = new PassThrough();
 
-  bytes(passthrough).then(common.mustCall(async (uint8arr) => {
+  bytes(passthrough).then(common.mustCall((uint8arr) => {
     assert(uint8arr instanceof Uint8Array);
     assert.strictEqual(uint8arr.byteLength, 10);
     assert.deepStrictEqual(Buffer.from(uint8arr), buf);