蓝鸟的函数然后

Question

我如何调用一个then（）函数？我是Bluebird的新手，之前我只是简单地触发回调来通知被调用的函数完成了它的工作。

这是我的“主代码”，它将区域设置数据插入到我的Mongo和Redis数据库中。

var promise = Language.findOne({}).exec() 

promise.then(function(languages) { 
    /* If collection is empty initialize it */ 
    if(!languages) 
     return insertLanguagesIntoMongoDB() 
}) 
.then(function() { 
    /* Make sure it's cached in Redis */ 
    return insertLanguagesIntoRedis() 
}) 
.catch(function(err) { 
    throw err 
}) 

这是我的功能看起来像，但它说：“回调不是一个函数”：

function insertLanguagesIntoRedis(callback) { 
    logger.info("Inserting languages into redis db") 
    var promise = Language.find({}).exec() 
    promise.then(function(languages) { 
     if(!languages) 
      throw new Error("Couldn't find any languages in MongoDB's Language collection") 

     var languageJson = [] 
     for(var i=0; i<languages.length; i++) { 
      var object = {} 
      object.id = languages[i].iso_code 
      object.text = languages[i].name_en 
      languageJson.push(object) 
     } 
     redis.set('languages', JSON.stringify(languageJson)) 
     return callback() 
    }) 
    .catch(function (err) { 
     throw err 
    }) 
} 

那么我将如何正确定义和调用我的insertLanguagesIntoRedis和insertLanguagesIntoMongoDB功能？

Answer 1

这些方针的东西可能会奏效：

1. 通过语言进入诺言链
2. 在链的最后返回的承诺进入下一步
3. 调整下一步接受语言
4. 调整insertLanguagesIntoRedis接受语言
5. 有insertLanguagesIntoRedis返回诺言链
6. 从insertLanguagesIntoRedis删除回调调用

VAR承诺= Language.findOne（{}）。EXEC（）每@Bergi

var promise = Language.findOne({}).exec() 

promise.then(function(languages) { 
    /* If collection is empty initialize it */ 
    if(!languages) 
     insertLanguagesIntoMongoDB() 
    return languages 
}) 
.then(function(languages) { 
    /* Make sure it's cached in Redis */ 
    return insertLanguagesIntoRedis(languages) 
}); 

function insertLanguagesIntoRedis(languages) { 
    logger.info("Inserting languages into redis db") 
    var promise = Language.find({}).exec() 
    return promise.then(function(languages) { 
     if(!languages) 
      throw new Error("Couldn't find any languages in MongoDB's Language collection") 

     var languageJson = [] 
     for(var i=0; i<languages.length; i++) { 
      var object = {} 
      object.id = languages[i].iso_code 
      object.text = languages[i].name_en 
      languageJson.push(object) 
     } 
     redis.set('languages', JSON.stringify(languageJson)) 
    }) 
}