stream: split stream/iter compression transforms out

Author: jasnell

benchmark/fs/bench-filehandle-pipetosync.js

@@ -30,13 +30,13 @@ function main({ compression, filesize, n }) {
   }
   closeSync(fd);
 
+  const { pipeToSync } = require('stream/iter');
   const {
-    pipeToSync,
     compressGzipSync,
     compressDeflateSync,
     compressBrotliSync,
     compressZstdSync,
-  } = require('stream/iter');
+  } = require('zlib/iter');
   const { open } = fs.promises;
 
   const compressFactory = {

benchmark/fs/bench-filehandle-pull-vs-webstream.js

@@ -153,7 +153,7 @@ async function runWebStream() {
 // Pull/iter path: pull() with uppercase transform + selected compression
 // ---------------------------------------------------------------------------
 async function benchPull(n, filesize, compression) {
-  const iter = require('stream/iter');
+  const iter = require('zlib/iter');
 
   const compressFactory = {
     gzip: iter.compressGzip,

benchmark/streams/iter-throughput-compression.js

@@ -80,7 +80,8 @@ function benchWebStream(chunk, datasize, n, totalOps) {
 }
 
 function benchIter(chunk, datasize, n, totalOps) {
-  const { pipeTo, compressGzip, decompressGzip } = require('stream/iter');
+  const { pipeTo } = require('stream/iter');
+  const { compressGzip, decompressGzip } = require('zlib/iter');
 
   async function run() {
     let remaining = datasize;

doc/api/fs.md

@@ -414,7 +414,8 @@ enabled.
 
 ```mjs
 import { open } from 'node:fs/promises';
-import { text, compressGzip } from 'node:stream/iter';
+import { text } from 'node:stream/iter';
+import { compressGzip } from 'node:zlib/iter';
 
 const fh = await open('input.txt', 'r');
 
@@ -432,7 +433,8 @@ const compressed = fh3.pull(compressGzip(), { autoClose: true });
 
 ```cjs
 const { open } = require('node:fs/promises');
-const { text, compressGzip } = require('node:stream/iter');
+const { text } = require('node:stream/iter');
+const { compressGzip } = require('node:zlib/iter');
 
 async function run() {
   const fh = await open('input.txt', 'r');
@@ -486,9 +488,8 @@ enabled.
 
 ```mjs
 import { open } from 'node:fs/promises';
-import {
-  textSync, pipeToSync, compressGzipSync, decompressGzipSync,
-} from 'node:stream/iter';
+import { textSync, pipeToSync } from 'node:stream/iter';
+import { compressGzipSync, decompressGzipSync } from 'node:zlib/iter';
 
 const fh = await open('input.txt', 'r');
 
@@ -503,9 +504,8 @@ pipeToSync(src.pullSync(compressGzipSync(), { autoClose: true }), dst.writer({ a
 
 ```cjs
 const { open } = require('node:fs/promises');
-const {
-  textSync, pipeToSync, compressGzipSync, decompressGzipSync,
-} = require('node:stream/iter');
+const { textSync, pipeToSync } = require('node:stream/iter');
+const { compressGzipSync, decompressGzipSync } = require('node:zlib/iter');
 
 async function run() {
   const fh = await open('input.txt', 'r');
@@ -1084,7 +1084,8 @@ enabled.
 
 ```mjs
 import { open } from 'node:fs/promises';
-import { from, pipeTo, compressGzip } from 'node:stream/iter';
+import { from, pipeTo } from 'node:stream/iter';
+import { compressGzip } from 'node:zlib/iter';
 
 // Async pipeline
 const fh = await open('output.gz', 'w');
@@ -1101,7 +1102,8 @@ await dst.close();
 
 ```cjs
 const { open } = require('node:fs/promises');
-const { from, pipeTo, compressGzip } = require('node:stream/iter');
+const { from, pipeTo } = require('node:stream/iter');
+const { compressGzip } = require('node:zlib/iter');
 
 async function run() {
   // Async pipeline

doc/api/index.md

@@ -70,6 +70,7 @@
 * [Web Streams API](webstreams.md)
 * [Worker threads](worker_threads.md)
 * [Zlib](zlib.md)
+* [Zlib Iterable Compression](zlib_iter.md)
 
 <hr class="line"/>