我如何在node.js的另一个promise函数中嵌套promise？

Question

我有一个由Promise函数包围的文件文件。我在这个函数中有一个数据库操作，这也需要另一个承诺。请检查下面

var p ; 
var ted = dep.map(function(name){ 

return new Promise(function(resolve,reject){ 
    /*..list of other tasks*/ 
    for(int i = 0 ;i<3<;i++){   
     p = Promise.resolve(savemongo(myobj,str)); // this is async function. How do I wait till this operation is complete and then move to next 
    } 
    resolve(); 

)}; 

代码现在，我一直在使用下面的代码

module.exports = Promise.all([ted,p]); 

我怎么等到我savetomongodb功能齐全该模块导出到不同的文件

林。

Answer 1

围绕整个事情由一个new Promise电话没有任何帮助。在它里面，你仍然有回拨地狱。不，把Promise.resolve()扔在一个不返回任何东西的函数也没有帮助。

您需要promisify异步基元，即异步的最小部分。在你的情况，这是distance.matrix和蒙戈的connect + insert：

function getMatrix(m, o, d) { 
    return new Promise(function(resolve, reject) { 
     m.matrix(o, d, function(err, distances) { 
      if (err) reject(err); 
      else  resolve(distances); 
     }); 
    }); 
} 

function save(url, store, k) { 
// cramming connect+insert in here is not optimal but let's not get into unnecessary detail 
    return new Promise(function(resolve, reject) { 
     MongoClient.connect(url, function(err, db) { 
      if (err) 
       reject(err); 
      else 
       db.collection(k).insert(store, function(err, results) { 
        if (err) reject(err); 
        else  resolve(results); 
        db.close(); 
       }); 
     }); 
    }); 
} 

现在我们有了这些，我们实际上可以使用它们，我们的承诺，组合成你实际上是在寻找：

module.exports = Promise.all(dep.map(function(name) { 
    distance.departure_time(name); 
    return getMatrix(distance, origins, destinations).then(function(distances) { 
     if (!distances) throw new Error('no distances'); 
     var promises = []; 
     if (distances.status == 'OK') { 
      for (var i=0; i < origins.length; i++) { 
       for (var j = 0; j < destinations.length; j++) { 
        var origin = distances.origin_addresses[i]; 
        var destination = distances.destination_addresses[j]; 
        if (distances.rows[0].elements[j].status == 'OK') { 
         var duration = distances.rows[i].elements[j].duration_in_traffic.value; 
         var myobj = { 
          destination: destination, 
          departure_time: name, 
          duration: duration 
         }; 
         var str = destination.replace(/[,\s]+/g, ''); 
         promises.push(save(url, myobj, str)); 
//         ^^^^^^^^^^^^^^^^^^^^^ 
        } 
       } 
      } 
     } 
     return Promise.all(promises); // now wait for all save results 
    }); 
}));