如何在`createReadStream`上模拟EventEmitter？

const { createReadStream } = require('fs');
const { EventEmitter } = require('events');

class ReadStreamWithEvent extends EventEmitter {
  constructor(path, options) {
    super();
    this.stream = createReadStream(path, options);

    // 监听可读流的data事件，并将数据传递给自定义的事件处理程序
    this.stream.on('data', (chunk) => {
      this.emit('customData', chunk);
    });

    // 监听可读流的end事件，并将其传递给自定义的事件处理程序
    this.stream.on('end', () => {
      this.emit('customEnd');
    });

    // 监听可读流的error事件，并将其传递给自定义的事件处理程序
    this.stream.on('error', (error) => {
      this.emit('customError', error);
    });
  }

  // 可以添加其他自定义方法和事件处理程序
}

// 创建自定义的可读流对象
const customStream = new ReadStreamWithEvent('file.txt');

// 监听自定义的事件
customStream.on('customData', (chunk) => {
  console.log('Received data chunk:', chunk);
});

customStream.on('customEnd', () => {
  console.log('Stream ended');
});

customStream.on('customError', (error) => {
  console.error('An error occurred:', error);
});