我如何从每个函数异步返回值?
[我知道这对人们来说是一个普遍的问题,我查阅了一些指南并查看了文档,但是我不了解正在发生的事情,并且希望获得一些帮助。
这是我正在使用的控制器功能:
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));
我如何从每个函数异步返回值?
[我知道这对人们来说是一个普遍的问题,我查阅了一些指南并查看了文档,但是我不了解正在发生的事情,并且希望获得一些帮助。
这是我正在使用的控制器功能:
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));