避免多流回调地狱

Question

当我打开多个流并且必须获得一个绝对end事件来完成逻辑时，如何避免使用类似递归的结构。

var someArray = ['file1', 'file2', 'file3'];

someArray.forEach(function( file ) {
    fs
        .createReadStream( file )
        .pipe( /* do some stuff */ )
        .on('data', function( usageInfo ) {

            // done?

        });
}

我有几个文件必须通过tp进行一些处理。如何设置一个事件，告诉我所有这些事件何时完成？目前，我得到的是每个end事件都是单独的。

我绝对可以同时开始每个视频流。我只需要以某种方式收集结局？

我可以为每个end事件调用一个函数调用并对其进行计数……虽然听起来很hacky？

我觉得有办法兑现诺言，但我不知道怎么做。

Answer 1

我觉得有办法兑现诺言，但我不知道怎么做。

就在这里。由于promise确实表示异步值，因此您将在一个流的结尾得到一个promise：

var p = new Promise(function(resolve, reject) {
    fs.createReadStream(file)
    .on('error', reject)
    .pipe(/* do some stuff */)
    .on('end', resolve)
    .on('error', reject); // call reject(err) when something goes wrong
});

它可以像使用p.then(functio(usageInfo) { console.log("stream ended"); })。

现在，如果您创建多个promise，其中一个用于数组中的文件名，则所有流将并行运行，并在完成时解析各自的promise。然后，您可以Promise.all用来收集-读取“
await”-将它们各自的所有结果转换成一系列结果的新承诺。

var promises = ['file1', 'file2', 'file3'].map(function(file) {
    return new Promise(function(resolve, reject) {
        …
    });
});
Promise.all(promises).then(function(usageInfos) {
    console.log("all of them done", usageInfos),
}, function(err) {
    console.error("(At least) one of them failed", err);
});