如何使用异步函数作为Array.filter（）的比较函数？

Question

对于我正在编写的Node JS模块，我想使用异步函数Stats.isFile()作为Array.filter()函数的回调函数。下面我有一个我想要实现的例子，但使用snychronous等价物。我无法弄清楚如何包装异步功能，以便我可以在Array.filter()函数中使用。

const fs = require('fs') 

exports.randomFile = function(dir = '.') { 
    fs.readdir(dir, (err, fileSet) => { 
     const files = fileSet.filter(isFile) 
     const rnd = Math.floor(Math.random() * files.length); 
     return files[rnd]) 
    }) 
} 

function isFile(item) { 
    return (fs.statSync(item)).isFile() 
} 

Answer 1

不能使用异步回调与.filter()。 .filter()需要同步结果，并且无法从异步操作中获取同步结果。所以，如果你打算使用异步fs.stat()，那么你必须使整个操作异步。

下面介绍一种方法。请注意，即使randomFile()需要异步传回其结果。我们在这里使用回调。

const path = require('path'); 
const fs = require('fs'); 

exports.randomFile = function(dir, callback) { 
    fs.readdir(dir, (err, files) => { 
     if (err) return callback(err); 

     function checkRandom() { 
      if (!files.length) { 
       // callback with an empty string to indicate there are no files 
       return callback(null, ""); 
      } 
      const randomIndex = Math.floor(Math.random() * files.length); 
      const file = files[randomIndex]; 
      fs.stat(path.join(dir, file), (err, stats) => { 
       if (err) return callback(err); 
       if (stats.isFile()) { 
        return callback(null, file); 
       } 
       // remove this file from the array 
       files.splice(randomIndex, 1); 
       // try another random one 
       checkRandom(); 
      }); 
     } 

     checkRandom(); 
    }); 
} 

而且，下面介绍如何使用另一个模块的异步接口。

// usage from another module: 
var rf = require('./randomFile'); 
fs.randomFile('/temp/myapp', function(err, filename) { 
    if (err) { 
     console.log(err); 
    } else if (!filename) { 
     console.log("no files in /temp/myapp"); 
    } else { 
     console.log("random filename is " + filename); 
    } 
}); 

Answer 2

如果你去异步，你必须从入口点去异步，所以randomFile需要一些方法来“回报”异步值（通常通过回调，承诺，或流）。

我不知道你的文件结构是怎么样的，而不是检查作为文件的所有条目，我会选择一个随机条目，检查它是否是文件，如果不是再试一次。

这可能看起来像这样

const fs = require('fs'); 
const path = require('path'); 

exports.randomFile = (dir = '.', cb) => { 
    fs.readdir(dir, (err, files) => { 
     if (err) { return cb(err); } 
     pickRandom(files.map((f) => path.join(dir, f)), cb); 
    }); 
} 

function pickRandom (files, cb) { 
    const rnd = Math.floor(Math.random() * files.length); 
    const file = files[rnd]; 
    fs.stat(file, (err, stats) => { 
     if (err) { 
      return cb(err); 
     } 
     if (stats.isFile()) { 
      return cb(null, file); 
     } else { 
      return pickRandom(files, cb); 
     } 
    }) 
}