![\"\"](\"https://david-dm.org/mqttjs/async-mqtt.svg?style=flat-square\")
\n\n\n ![\"\"](\"https://img.shields.io/npm/dt/async-mqtt.svg?style=flat-square\")
\n\n\n ![\"\"](\"https://img.shields.io/npm/v/async-mqtt.svg?style=flat-square\")
\n\n\n\n
![\"\"](\"https://img.shields.io/badge/code%20style-standard-brightgreen.svg?style=flat-square\"){kind=icon}
\n\nPromise wrapper over MQTT.js
\n\n\n**IMPORTANT: Make sure you handle rejections from returned promises because they won't crash the process**\n\n## API\n\nThe API is the same as [MQTT.js](https://github.com/mqttjs/MQTT.js#api), except the following functions now return promises instead of taking callbacks\n\n- publish\n- subscribe\n- unsubscribe\n- end\n\n\n## Example\n\n```javascript\nconst MQTT = require(\"async-mqtt\");\n\nconst client = MQTT.connect(\"tcp://somehost.com:1883\");\n\n// When passing async functions as event listeners, make sure to have a try catch block\n\nconst doStuff = async () => {\n\n\tconsole.log(\"Starting\");\n\ttry {\n\t\tawait client.publish(\"wow/so/cool\", \"It works!\");\n\t\t// This line doesn't run until the server responds to the publish\n\t\tawait client.end();\n\t\t// This line doesn't run until the client has disconnected without error\n\t\tconsole.log(\"Done\");\n\t} catch (e){\n\t\t// Do something about it!\n\t\tconsole.log(e.stack);\n\t\tprocess.exit();\n\t}\n}\n\nclient.on(\"connect\", doStuff);\n```\n\nAlternately you can skip the event listeners and get a promise.\n\n```js\nconst MQTT = require(\"async-mqtt\");\n\nrun()\n\nasync function run() {\n const client = await MQTT.connectAsync(\"tcp://somehost.com:1883\")\n\n console.log(\"Starting\");\n\ttry {\n\t\tawait client.publish(\"wow/so/cool\", \"It works!\");\n\t\t// This line doesn't run until the server responds to the publish\n\t\tawait client.end();\n\t\t// This line doesn't run until the client has disconnected without error\n\t\tconsole.log(\"Done\");\n\t} catch (e){\n\t\t// Do something about it!\n\t\tconsole.log(e.stack);\n\t\tprocess.exit();\n\t}\n}\n\n```\n\n## Wrapping existing client\n\n```javascript\nconst { AsyncClient } = require(\"async-mqtt\");\n\nconst client = getRegularMQTTClientFromSomewhere();\n\nconst asyncClient = new AsyncClient(client);\n\nasyncClient.publish(\"foo/bar\", \"baz\").then(() => {\n\tconsole.log(\"We async now\");\n\treturn asyncClient.end();\n});\n```\n","maintainers":[{"name":"matteo.collina","email":"hello@matteocollina.com"},{"name":"rangermauve","email":"rangermauve@hotmail.com"},{"name":"tabrizian","email":"iman.tabrizian@gmail.com"}],"time":{"modified":"2022-09-06T15:48:51.163Z","created":"2017-02-26T22:01:05.258Z","1.0.0":"2017-02-26T22:01:05.258Z","1.0.1":"2017-03-10T20:53:09.729Z","2.0.0":"2018-09-14T14:45:57.155Z","2.2.0":"2019-02-25T15:21:38.080Z","2.2.1":"2019-03-25T14:06:51.404Z","2.3.0":"2019-05-31T15:40:35.013Z","2.4.0":"2019-08-07T21:17:06.712Z","2.4.1":"2019-08-13T18:59:24.804Z","2.4.2":"2019-08-19T14:50:31.795Z","2.5.0":"2020-02-03T17:38:00.557Z","2.6.0":"2020-05-24T20:12:25.849Z","2.6.1":"2020-06-29T16:24:54.157Z","2.6.2":"2022-01-23T17:50:12.794Z","2.6.3":"2022-09-06T15:48:51.077Z"},"homepage":"https://github.com/mqttjs/async-mqtt#readme","keywords":["mqtt","promise","async","publish","subscribe"],"repository":{"type":"git","url":"git+https://github.com/mqttjs/async-mqtt.git"},"author":{"name":"rangermauve"},"bugs":{"url":"https://github.com/mqttjs/async-mqtt/issues"},"license":"MIT","readmeFilename":"README.md"}