使用async library
我可以使用以下代码save
数据
function save(callback){
async.parallel([
function(cb){
Collection1.collection.insert(collections1,cb);
},
function(cb){
Collection2.collection.insert(collections2,cb);
},
function(cb){
Collection3.collection.insert(collections3,cb);
}
],callback);
}
save(function(){
console.log(arguments);
});
我如何修改save
函数,使其返回promise
?
save()
.then(function(){
console.log('success');
})
.catch(function(){
console.log('error');
})
现在我的问题是,如何在不使用async library
的情况下使用 promise 编写save
函数?
function save(){
return new Promise(function(resolve,reject){
//save collections here?? or any other way???
})
}
在函数中使用Promise.all
save
然后您就可以按预期使用它
function save(){
var promises = [
new Promise(function(resolve, reject) {
Collection1.collection.insert(collections1, function(err, done){
if(err)
reject(err);
else
resolve(done);
});
}),
new Promise(function(resolve, reject) {
Collection2.collection.insert(collections2, function(err, done){
if(err)
reject(err);
else
resolve(done);
});
}),
new Promise(function(resolve, reject) {
Collection3.collection.insert(collections3, function(err, done){
if(err)
reject(err);
else
resolve(done);
});
})
];
return Promise.all(promises);
}
save().then(function(){
console.log('success');
}).catch(function(){
console.log('error');
})