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

Question

我正在使用filewalkernpm 包浏览文件。

一旦满足特定条件，我试图通过退出流来限制将在流中读取的文件数量。（例如流式传输 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()
    })

有没有办法手动取消/退出流？

Answer 1

虽然这不是问题的答案，但我通过将filewalkerlibrary替换为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()
})