最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

我如何从每个函数异步返回值?

运维笔记admin10浏览0评论

我如何从每个函数异步返回值?

我如何从每个函数异步返回值?

[我知道这对人们来说是一个普遍的问题,我查阅了一些指南并查看了文档,但是我不了解正在发生的事情,并且希望获得一些帮助。

这是我正在使用的控制器功能:

exports.appDetail = function (req, res) {
  appRepo.findWithId(req.params.id, (err, myApp) => {
    if (err) {
      console.log(err)
    }
    getDeviceData(myApp.devices, (err, myDeviceData) => {
      if (err) console.log(err)
      console.log(JSON.stringify(myDeviceData) + '  ||  myDeviceData')
      // construct object to be returned
      let appsDataObject = {
        name: myApp.name,
        user_id: myApp.user_id,
        devices: myDeviceData,
        permissions: myApp.permissions
      }
      return res.status(200).send(appsDataObject)
    })
  })
}

// write async function here
const getDeviceData = function (devices, callback) {
  let devicesDataArray = []
  async.each(devices, function (device, cb) {
    deviceRepo.findById(new ObjectID(device), (err, myDevice) => {
      if (err) {
        cb(err)
      }
      // get device data, push to devices array
      let deviceObj = {
        name: myDevice.name,
        version: myDevice.version
      }
      devicesDataArray.push(deviceObj)
      console.log(JSON.stringify(devicesDataArray) + '  ||  devicesDataAray after obj push')
    })
    cb(null, devicesDataArray)
  }, function (err) {
    // if any of the file processing produced an error, err would equal that error
    if (err) console.log(err)
  })
  callback(null, devicesDataArray)
}

我本来是用for循环和回调编写的,但是我认为这样做是不可能的(尽管我不确定)。如果有更好的方法来进行异步循环,请告诉我。

第8行上有一个日志语句myDeviceData。这应该通过回调返回我想要的数据,但是此日志语句始终返回为空。并且由于其他日志语句表明数据格式正确,所以问题一定出在通过getDeviceData()的回调返回我需要的数据。大概,callback(null, devicesDataArray)应该这样做。

显然,我不理解这些异步功能应该如何工作。有人可以帮我了解如何从这些async.each函数中获取值吗?谢谢。

编辑:我对代码进行了重构,以使其更清晰,更好地解决问题,并且我查明了问题出在哪里。首先,此函数将devicesDataArray定义为一个空数组,最后,我返回该数组。内部的一切都应该发生,但是我不知道如何告诉返回要等到数组不为空时,如果这是有道理的,这是新代码:

let getData = async function (devices) {
  let devicesDataArray = []
  for (let i = 0; i < devices.length; i++) {
    deviceRepo.findById(new ObjectID(devices[i]), async (err, myDevice) => {
      if (err) {
        console.log(err)
      }
      console.log(JSON.stringify(myDevice) + '  ||  myDevice')
      let deviceObj = await {
        name: myDevice.name,
        version: myDevice.version
      }
      console.log(JSON.stringify(deviceObj) + '  ||  deviceObj')
      await devicesDataArray.push(deviceObj)
      console.log(JSON.stringify(devicesDataArray) + '  ||  devicesDataArray after push')
    })
  }
  console.log(JSON.stringify(devicesDataArray) + '  ||  devicesDataArray before return')
  return Promise.all(devicesDataArray)  // problem is here.
}

感谢您对理解此问题的任何帮助。

回答如下:

这里我们使用的是Promise

Promise对象将立即返回,我们在其中执行异步代码。

const someFuncThatTakesTime = () => {
  // Here is our ASYNC 
  return new Promise((resolve, reject) => {
    // In here we are synchronous again. 
    const myArray = [];  
    for(x = 0; x < 10; x++) {
      myArray.push(x);
    }
    
    // Here is the callback    
    setTimeout(() => resolve(myArray), 3000);  
  });
};

someFuncThatTakesTime().then(array => console.log(array));
发布评论

评论列表(0)

  1. 暂无评论