使用异步/等待不工作

Question

我有一个函数，它做异步数据库搜索操作。

var get_all_channels = function { 
    return new Promise(()=> { 
     db.find({type:'pricing'},{channel_name:1},function(err,docs){ 
     if(err) 
      return err; 
     var c = [] 
     docs.forEachOf(function(ch){ 
      c.push(ch['channel_name']) 
     }) 
     return c; 
    }) 
    }) 
} 

async function send(){ 
    return await get_all_channels() 
} 
function calculate(){ 
    send().then(res => alert(res))  
} 

这里，上述功能不起作用。我不知道为什么？请帮我修复这个功能。

Answer 1

您需要解决的结果的承诺，该阵列c，在get_all_channels：

var get_all_channels = function { 
    return new Promise((resolve, reject)=> { 
     db.find({type:'pricing'},{channel_name:1},function(err,docs){ 
     if(err) { 
      reject(err) 
      return 
     } 

     var c = [] 
     docs.forEachOf(function(ch){ 
      c.push(ch['channel_name']) 
     }) 

     resolve(c) 
    }) 
    }) 
} 

而且在calculate，你也可以使用await如果你想，并通过@netchkin如指出，你不需要send的async/await只要它只是返回await：

function send(){ 
    return get_all_channels() 
} 

async function calculate(){ 
    alert(await send()) 
}