使用文件漫步器时，在“ on('exit”)之前手动出口流

Question

我正在使用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()
    })

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

Answer 1

虽然这不是回答问题的回答，但我通过用walk替换filewalker库解决了此问题。它基本上做同样的事情，只是它具有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()
})