stream.Duplex.from(src)

• src <Stream> | <Blob> | <ArrayBuffer> | <string> | <Iterable> | <AsyncIterable> | <AsyncGeneratorFunction> | <AsyncFunction> | <Promise> | <Object> | <ReadableStream> | <WritableStream>

用于创建双工流的实用方法。

【A utility method for creating duplex streams.】

• Stream 将可写流转换为可写的 Duplex，将可读流转换为可读的 Duplex。
• Blob 转换为可读的 Duplex。
• string 转换为可读的 Duplex。
• ArrayBuffer 转换为可读的 Duplex。
• AsyncIterable 可以转换为可读的 Duplex。不能产生 null。
• AsyncGeneratorFunction 会转换为可读/可写的转换流 Duplex。必须将源 AsyncIterable 作为第一个参数。不能生成 null。
• AsyncFunction 会转换为可写的 Duplex。必须返回 null 或 undefined
• Object ({ writable, readable }) 将 readable 和 writable 转换为 Stream，然后将它们组合成 Duplex，其中 Duplex 会写入 writable 并从 readable 读取。
• Promise 会转换为可读的 Duplex。值 null 会被忽略。
• ReadableStream 转换为可读的 Duplex。
• WritableStream 转换为可写的 Duplex。
• 返回：<stream.Duplex>

如果将包含 Promise 的 Iterable 对象作为参数传入，可能会导致未处理的拒绝。

【If an Iterable object containing promises is passed as an argument, it might result in unhandled rejection.】

const { Duplex } = require('node:stream');

Duplex.from([
  new Promise((resolve) => setTimeout(resolve('1'), 1500)),
  new Promise((_, reject) => setTimeout(reject(new Error('2')), 1000)), // Unhandled rejection
]); 拷贝