再帰Promise.all？

Question

私は一連の約束が完了するのを待っています。私はPromise.allでこれを行うことができると知っていますが、それらの約束のうちの1つが約束のリストに新しい約束をするとき、何をすべきか分かりません。

例：

asyncFunction(...).then(result => { 
    // do something 
}); 


asyncFunction(...).then(result => { 
    for(let row of result) { 
     asyncFunction(row); 
    } 
}); 


console.log(promises.length); // 2 
await Promise.all(promises); 
console.log(promises.length); // 5 

asyncFunctionのようなものである：ここに起こった何

const asyncFunction = (...args) => { 
    let result = new Promise((resolve, reject) => { 
     pool.query(...args, (err, rows, fields) => { 
      if (err) { 
       reject(err); 
      } else { 
       resolve(rows); 
      } 
     }); 
    }); 
    promises.push(result); 
    return result; 
}; 

するのでpromises.lengthしかし2で、私のpromises配列にasyncFunctionプッシュ約束への最初の二つの呼び出しということですそれらが完了するのを待ってから、Promise.allが既にその配列を評価しているので、第2のものが配列に新しい約束を押し込むので、待たれていません。

どのように私はすべての約束と新しいものを待つことができますか？この例ではawait Promise.all(promises)を2回呼び出すだけで動作しますが、これは無限になります。私は単にこれでPromise.allを交換し、正常に動作すべきだと思う

function recursiveAll(array) { 
    // Wait for the promises to resolve 
    return Promise.all(array).then(function(result) { 
     // If no new promises were added, return the result 
     if (result.length == array.length) 
      return result; 
     // If new promises were added, re-evaluate the array. 
     return recursiveAll(array); 
    }); 
} 

Answer 1

while(promises.length) { 
    await promises.shift(); 
} 

Answer 2

：あなたは、各反復の後にリストの状態を再評価し、すべての再帰関数を書くことができます

Answer 3

ています副作用のある関数の問題。

あなたのコードは抽象的な抽象的な答えですが、promises-アレイを完全に削除することをお勧めします。

const asyncFunction = (...args) => { 
    return new Promise((resolve, reject) => { 
     pool.query(...args, (err, rows, fields) => { 
      if (err) { 
       reject(err); 
      } else { 
       resolve(rows); 
      } 
     }); 
    }); 
} 

と

asyncFunction(...).then(result => Promise.all(result.map(row => asyncFunction(row)))); 

限り、私はあなたの意図を理解するように、これは配列内の配列の入れ子構造になるはずである、最悪の場合には、今WICHのみALL取得するために平坦化する必要があります値、および前のものによってトリガーされる値。