toReadable(source[, options])

• source <AsyncIterable> 它的块必须与 pull() 或 from() 的返回值 <Uint8Array[]> 相符。
• options <Object>
  • highWaterMark <number> 在应用反压之前的内部缓冲区大小（以字节为单位）。默认值： 65536（64 KB）。
  • signal <AbortSignal> 可选信号以中止可读流。
• 返回：<stream.Readable>

从 source（stream/iter API 使用的本地批处理格式）创建一个字节模式的 stream.Readable。每个批处理中产生的 Uint8Array 都会作为单独的块推入可读流。

🌐 Creates a byte-mode stream.Readable from the source (the native batch format used by the stream/iter API). Each Uint8Array in a yielded batch is pushed as a separate chunk into the Readable.

import { createWriteStream } from 'node:fs';
import { from, pull, toReadable } from 'node:stream/iter';
import { compressGzip } from 'node:zlib/iter';

const source = pull(from('hello world'), compressGzip());
const readable = toReadable(source);

readable.pipe(createWriteStream('output.gz'));const { createWriteStream } = require('node:fs');
const { from, pull, toReadable } = require('node:stream/iter');
const { compressGzip } = require('node:zlib/iter');

const source = pull(from('hello world'), compressGzip());
const readable = toReadable(source);

readable.pipe(createWriteStream('output.gz'));拷贝