feat(streams): stabilize toBytes (#7043)

Author: tomas-zijdemans

encoding/unstable_base32_stream.ts

@@ -134,7 +134,7 @@ export class Base32EncoderStream<T extends "string" | "bytes">
  *   Base32DecoderStream,
  *   Base32EncoderStream,
  * } from "@std/encoding/unstable-base32-stream";
- * import { toBytes } from "@std/streams/unstable-to-bytes";
+ * import { toBytes } from "@std/streams/to-bytes";
  *
  * const readable = (await Deno.open("./deno.lock"))
  *   .readable

encoding/unstable_base32_stream_test.ts

@@ -2,7 +2,7 @@
 
 import { assertEquals } from "@std/assert";
 import { toText } from "@std/streams";
-import { toBytes } from "@std/streams/unstable-to-bytes";
+import { toBytes } from "@std/streams/to-bytes";
 import { FixedChunkStream } from "@std/streams/unstable-fixed-chunk-stream";
 import { encodeBase32 } from "./unstable_base32.ts";
 import {

encoding/unstable_base64_stream.ts

@@ -138,7 +138,7 @@ export class Base64EncoderStream<T extends "string" | "bytes">
  *   Base64DecoderStream,
  *   Base64EncoderStream,
  * } from "@std/encoding/unstable-base64-stream";
- * import { toBytes } from "@std/streams/unstable-to-bytes";
+ * import { toBytes } from "@std/streams/to-bytes";
  *
  * const readable = (await Deno.open("./deno.lock"))
  *   .readable

encoding/unstable_base64_stream_test.ts

@@ -2,7 +2,7 @@
 
 import { assertEquals } from "@std/assert";
 import { toText } from "@std/streams";
-import { toBytes } from "@std/streams/unstable-to-bytes";
+import { toBytes } from "@std/streams/to-bytes";
 import { FixedChunkStream } from "@std/streams/unstable-fixed-chunk-stream";
 import { encodeBase64 } from "./unstable_base64.ts";
 import {

encoding/unstable_hex_stream.ts

@@ -104,7 +104,7 @@ export class HexEncoderStream<T extends "string" | "bytes">
  *   HexDecoderStream,
  *   HexEncoderStream,
  * } from "@std/encoding/unstable-hex-stream";
- * import { toBytes } from "@std/streams/unstable-to-bytes";
+ * import { toBytes } from "@std/streams/to-bytes";
  *
  * const readable = (await Deno.open("./deno.lock"))
  *   .readable

encoding/unstable_hex_stream_test.ts

@@ -2,7 +2,7 @@
 
 import { assertEquals } from "@std/assert";
 import { toText } from "@std/streams";
-import { toBytes } from "@std/streams/unstable-to-bytes";
+import { toBytes } from "@std/streams/to-bytes";
 import { FixedChunkStream } from "@std/streams/unstable-fixed-chunk-stream";
 import { encodeHex } from "./unstable_hex.ts";
 import { HexDecoderStream, HexEncoderStream } from "./unstable_hex_stream.ts";

streams/deno.json

@@ -19,7 +19,7 @@
     "./to-array-buffer": "./to_array_buffer.ts",
     "./to-blob": "./to_blob.ts",
     "./unstable-to-byte-stream": "./unstable_to_byte_stream.ts",
-    "./unstable-to-bytes": "./unstable_to_bytes.ts",
+    "./to-bytes": "./to_bytes.ts",
     "./to-json": "./to_json.ts",
     "./unstable-to-lines": "./unstable_to_lines.ts",
     "./to-text": "./to_text.ts",

streams/mod.ts

@@ -30,6 +30,7 @@ export * from "./text_delimiter_stream.ts";
 export * from "./text_line_stream.ts";
 export * from "./to_array_buffer.ts";
 export * from "./to_blob.ts";
+export * from "./to_bytes.ts";
 export * from "./to_json.ts";
 export * from "./to_text.ts";
 export * from "./to_transform_stream.ts";

streams/unstable_to_bytes.ts streams/to_bytes.tsstreams/unstable_to_bytes.ts renamed to streams/to_bytes.ts

@@ -5,14 +5,12 @@
  * Converts a {@linkcode ReadableStream} of {@linkcode Uint8Array}s to a
  * {@linkcode Uint8Array}. Works the same as {@linkcode Response.bytes}.
  *
- * @experimental **UNSTABLE**: New API, yet to be vetted.
- *
  * @param stream A `ReadableStream` of `Uint8Array`s to convert into a `Uint8Array`.
  * @returns A `Promise` that resolves to the `Uint8Array`.
  *
  * @example Basic usage
  * ```ts
- * import { toBytes } from "@std/streams/unstable-to-bytes";
+ * import { toBytes } from "@std/streams/to-bytes";
  * import { assertEquals } from "@std/assert";
  *
  * const stream = ReadableStream.from([

streams/to_bytes_test.ts

@@ -0,0 +1,35 @@
+// Copyright 2018-2026 the Deno authors. MIT license.
+
+import { assertEquals, assertRejects } from "@std/assert";
+import { toBytes } from "./to_bytes.ts";
+
+Deno.test("toBytes() concatenates multiple chunks", async () => {
+  const stream = ReadableStream.from([
+    new Uint8Array([1, 2, 3, 4, 5]),
+    new Uint8Array([6, 7]),
+    new Uint8Array([8, 9]),
+  ]);
+
+  const bytes = await toBytes(stream);
+  assertEquals(bytes, new Uint8Array([1, 2, 3, 4, 5, 6, 7, 8, 9]));
+});
+
+Deno.test("toBytes() returns empty Uint8Array for empty stream", async () => {
+  const stream = ReadableStream.from([]);
+  const bytes = await toBytes(stream);
+  assertEquals(bytes, new Uint8Array());
+});
+
+Deno.test("toBytes() rejects when stream errors", async () => {
+  const stream = new ReadableStream({
+    start(controller) {
+      controller.error(new Error("boom"));
+    },
+  });
+
+  await assertRejects(
+    () => toBytes(stream),
+    Error,
+    "boom",
+  );
+});