在使用 filewalker 时到达 `on('exit')` 事件之前手动退出流

Exit stream manually before `on('exit')` event is reached while using filewalker

我正在使用 filewalker npm 包浏览文件。

我试图通过在满足特定条件后退出流来限制将在流中读取的文件数量。 (例如流式传输 5 个文件路径)而不是等待 exit 事件。 (这是由于大量文件,我想分页流)

  getFilePath: (dirPath, fileMatchExpression) => {
    return new Promise((resolve, reject) => {
      filewalker(dirPath)
      .on('file', filePath => {
        if (filePath.match(fileMatchExpression)){
          resolve(filePath)
          // how to force exit on this line?
        }
      })
      .on('error', err => reject(err))
      .on('done', _ => console.log('DONE!!'))
      .walk()
    })

有没有办法 cancel/exit 手动直播?

虽然这不是问题的答案,但我通过将 filewalker 库替换为 walk 解决了这个问题。它基本上做同样的事情,除了它有 next 功能,允许我控制程序是否接下来执行。

const walk = require('walk')
let walker = walk.walk(dataDirPath, {followingLinks: false})
let counter = 0
walker.on('file', (root, stat, next) => {
  console.log(root + '/' + stat.name);
  counter++
  if(counter < 1) next()
})