如何在fs.promises中使用fs.createReadstream

const fs = require('fs');

const readStream = fs.createReadStream('文件路径');

readStream.on('data', (chunk) => {
  // 处理流的数据
});

readStream.on('end', () => {
  // 关闭可读流
  readStream.close();
});

const fs = require('fs');

const readStream = fs.createReadStream('文件路径');

readStream.on('data', (chunk) => {
  // 处理流的数据
  console.log(chunk.toString());
});

readStream.on('end', () => {
  // 关闭可读流
  readStream.close();
});

const fs = require('fs');
const { promisify } = require('util');

const createReadStream = promisify(fs.createReadStream);

async function readFile(filePath) {
  const readStream = createReadStream(filePath);
  let data = '';

  readStream.on('data', (chunk) => {
    // 处理流的数据
    data += chunk.toString();
  });

  await new Promise((resolve) => {
    readStream.on('end', () => {
      // 关闭可读流
      readStream.close();
      resolve();
    });
  });

  return data;
}

// 使用示例
readFile('文件路径')
  .then((data) => {
    console.log(data);
  })
  .catch((error) => {
    console.error(error);
  });