duplex([options])

• options <Object>
  • highWaterMark <number> 双向的缓冲区大小。 默认值: 4。
  • backpressure <string> 双向策略。 默认: 'strict'。
  • signal <AbortSignal> 两个通道的取消信号。
  • a <Object> 特定于 A 到 B 方向的选项。覆盖共享选项。
    • highWaterMark <number>
    • backpressure <string>
  • b <Object> 特定于 B 到 A 方向的选项。覆盖共享选项。
    • highWaterMark <number>
    • backpressure <string>
• 返回:<Array> 一对 [channelA, channelB] 双工通道。

创建一对连接的双工通道以实现双向通信,类似于 socketpair()。写入一个通道的写入端的数据会出现在另一个通道的可读端。

🌐 Create a pair of connected duplex channels for bidirectional communication, similar to socketpair(). Data written to one channel's writer appears in the other channel's readable.

每个通道都有:

🌐 Each channel has:

• writer — 一个用于向节点发送数据的 [Writer 接口][] 对象。
• readable — 一个用于从对等方读取数据的 AsyncIterable<Uint8Array[]>。
• close() — 关闭该端的通道(幂等)。
• [Symbol.asyncDispose]() — 为 await using 提供异步释放支持。

import { duplex, text } from 'node:stream/iter';
const [client, server] = duplex();
// Server echoes back
const serving = (async () => {
 for await (const chunks of server.readable) {
 await server.writer.writev(chunks);
 }
})();
await client.writer.write('hello');
await client.writer.end();
console.log(await text(server.readable)); // handled by echo
await serving;const { duplex, text } = require('node:stream/iter');
async function run() {
 const [client, server] = duplex();
 // Server echoes back
 const serving = (async () => {
 for await (const chunks of server.readable) {
 await server.writer.writev(chunks);
 }
 })();
 await client.writer.write('hello');
 await client.writer.end();
 console.log(await text(server.readable)); // handled by echo
 await serving;
}
run().catch(console.error);拷贝