WriteStream与WritableStream的差异及process.stdout转换问询

问题背景 #

执行以下代码时出现报错：

const response = await fetch('https://www.google.com')
response.body.pipeThrough(new TextDecoderStream()).pipeTo(process.stdout)

报错信息：

TypeError [ERR_INVALID_ARG_TYPE]: The "transform.writable" property must be an instance of WritableStream. Received an instance of WriteStream

核心问题 #

1. WriteStream与WritableStream有何区别？
2. 能否将作为WriteStream的process.stdout转换为WritableStream？

失败的尝试 #

尝试直接设置process.stdout.writable为true，未成功：

// fails
process.stdout.writable = true
response.body.pipeTo(process.stdout)

当前可用的有效方法 #

以下两种方法可以正常工作：
方法一：通过异步迭代器手动写入

// works
const response = await fetch('http://www.google.com')
const reader = response.body.pipeThrough(new TextDecoderStream())
for await (const chunk of reader){
  process.stdout.write(chunk)
}

方法二：用Readable.fromWeb转换Web流后使用Node.js管道

// works
const { Readable } = require('stream');
Readable.fromWeb(response.body).pipe(process.stdout)

额外疑惑 #

尚未完全理解Web流与Node.js流的差异，原以为所有I/O流可互相转换，使用Readable.fromWeb虽有效，但不清楚其原理，且担心效率问题。此外，是否可对process.stdout执行反向转换，例如通过类似response.body.pipeTo(new WritableStream(process.stdout))的方式实现？

问题解答 #

1. WriteStream 与 WritableStream 的区别 #

• 所属生态不同：
  • WriteStream 是Node.js原生流类型，属于Node.js的stream模块，基于Node.js的事件循环和I/O模型设计，用于处理本地文件、控制台等Node.js环境的输出。
  • WritableStream 是WHATWG制定的Web Streams API标准接口，适用于浏览器、Deno以及Node.js的Web兼容层，和Node.js流属于完全独立的两套体系。
• API与使用方式差异：
  • Node.js的WriteStream使用write()、end()方法，通过'finish'、'error'等事件处理状态，是基于事件驱动的API。
  • Web的WritableStream则依赖pipeTo()、close()等方法，结合Promise处理异步操作，接口更贴合现代异步编程范式。
• 内部机制差异：两者的背压处理、数据缓冲逻辑完全独立，没有直接兼容的基础，不能直接混用。

2. 转换process.stdout为WritableStream的方法 #

Node.js提供了stream.Writable.toWeb()方法，可以将Node.js的WriteStream（process.stdout属于此类）转换为标准的Web WritableStream，从而直接配合Web流的pipeTo()使用：

const { Writable } = require('stream');

const response = await fetch('https://www.google.com');
const webStdout = Writable.toWeb(process.stdout);
response.body.pipeThrough(new TextDecoderStream()).pipeTo(webStdout);

关于Readable.fromWeb的原理与效率 #

• 原理：Readable.fromWeb()是Node.js官方提供的桥接API，它将Web标准的ReadableStream包装成Node.js的stream.Readable实例，内部自动处理两种流之间的背压同步、数据格式转换（比如将Web流的Uint8Array转为Node.js的Buffer），让Web流能适配Node.js的pipe()管道机制。
• 效率：这种桥接的性能损耗可以忽略不计，Node.js内部已经做了针对性优化，日常使用中不会出现明显的效率问题，和使用同生态的流几乎无差异。

反向转换的可行性 #

你提到的response.body.pipeTo(new WritableStream(process.stdout))方式不可行，因为Web的WritableStream构造函数不接受Node.js的WriteStream作为参数。正确的反向转换方式就是使用Writable.toWeb()，它能将Node.js的WriteStream转换为符合Web标准的WritableStream，完美适配Web流的pipeTo()操作。

内容的提问来源于stack exchange，提问作者Neo Phyte