双工流示例

\An example duplex stream

下面说明了一个 Duplex 流的简单示例,它封装了一个假设的更底层的源对象,数据可以写入到该源对象中,并且可以从中读取数据,尽管使用的 API 与 Node.js 流不兼容。下面说明了一个 Duplex 流的简单示例,它缓冲通过 Writable 接口传入的写入数据,这些数据通过 Readable 接口读回。

\The following illustrates a simple example of a Duplex stream that wraps a hypothetical lower-level source object to which data can be written, and from which data can be read, albeit using an API that is not compatible with Node.js streams. The following illustrates a simple example of a Duplex stream that buffers incoming written data via the Writable interface that is read back out via the Readable interface.

const { Duplex } = require('node:stream');
const kSource = Symbol('source');
class MyDuplex extends Duplex {
 constructor(source, options) {
 super(options);
 this[kSource] = source;
 }
 _write(chunk, encoding, callback) {
 // The underlying source only deals with strings.
 if (Buffer.isBuffer(chunk))
 chunk = chunk.toString();
 this[kSource].writeSomeData(chunk);
 callback();
 }
 _read(size) {
 this[kSource].fetchSomeData(size, (data, encoding) => {
 this.push(Buffer.from(data, encoding));
 });
 }
} 拷贝

Duplex 流最重要的方面是 Readable 和 Writable 端彼此独立运行,尽管它们共存于单个对象实例中。

\The most important aspect of a Duplex stream is that the Readable and Writable sides operate independently of one another despite co-existing within a single object instance.