Estoy trabajando para obtener datos de un corredor MQTT de forma dinámica para algunos temas diferentes. Estoy luchando con la función asíncrona que se supone que obtiene los datos.
async function getData(path){ client.subscribe(path); let data = await client.on('message', function(topic, message){ data = JSON.parse(message.toString()); console.log(data); return JSON.parse(message.toString()) }) console.log(data); return data }El archivo console.log fuera de la función client.on se muestra primero en la consola y no muestra la información correcta, el archivo console.log dentro de la función client.on muestra los datos correctos. La función getData se llama más tarde en un useEffect y se empareja de la siguiente manera
getData(path).then((data)=>{ console.log(data) }Los datos en este console.log son la misma información incorrecta de antes. Intenté cambiar la ubicación de las declaraciones de espera, pero eso no lo solucionó. ¿Necesito encadenar una promesa adicional dentro de la función getData para esperar a que se reciba el mensaje?
Es porque la función client.on usa callback, no Promise . En su caso, no está esperando que finalice la devolución de llamada antes de devolver data . Puede usar async-mqtt (suponiendo que esté usando mqtt al principio) o crear una Promise :
async function getData(path) { client.subscribe(path); return new Promise((resolve, reject) => { client.on('message', function(topic, message) { return resolve(JSON.parse(message.toString())); }); }); }