Await/Promise for receiving next message feature discussion

[cameronelliott]

This is the 2nd feature I would like to discuss adding to the library.

Which is also a feature request for an excellent raw websockets library.

The feature is described here

Basically, it allows promises to be used to await the next message received, rather than just relying on a callback.

Example from linked issue:

await ws.open();

while (true) {
  data = await ws.recv();
  ws.send(data);
}

See discussion in raw websockets project for more details: here

I make try to implement this, but I am not a fantastic JS, nor promises programmer, but if someone else
wants to help or try to do this, please let me know!

Thanks for this awesome async/MQTT library!

[cameronelliott]

I would also like feedback from the maintainers if they would be interested in a PR for this feature?

[cameronelliott]

Actually, I would love to get some feedback/input from the maintainers on the use or submission of this functionality.
I will sit tight. I won't submit PR until after discussion.
https://github.com/x186k/async-mqtt-x186k

[RangerMauve]

Regarding awaiting events, I think the EventEmitter.once(emitter, eventName) API in the node docs is what people tend to use.

I think it'd be cool to return async iterables from events like for await (const data of mqtt.on('event')) { etc }