我如何在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 
    }); 
}));