Documentation : three more examples ? about async-mqtt HOT 6 CLOSED

const MQTT = require("async-mqtt");

const client = MQTT.connect("tcp://somehost.com:1883");

// When passing async functions as event listeners, make sure to have a try catch block

const doStuff = async () => {

	console.log("Starting");
	try {

		client.on('message', (topic, message) => console.log(topic, message);

		await client.subscribe("wow/#");
		await client.publish("wow/so/cool", "It works!");
		// This line doesn't run until the server responds to the publish
		
		await client.unsubscribe("wow/#");
		await client.publish("wow/so/cool", "Won't show up since it's not subscribed!");
		
		await client.end();
		// This line doesn't run until the client has disconnected without error
		console.log("Done");
	} catch (e){
		// Do something about it!
		console.log(e.stack);
		process.exit();
	}
}

client.on("connect", doStuff);

    const run = async() =>{        

        console.log("Starting");
        try {
            client.on("message", (topic, message) =>{
                var rfidPayload = JSON.parse(message.toString());
                console.log(rfidPayload);
                var carKeyIn = rfidPayload.carKey;
                var renterIDIn = rfidPayload.renterID;
                var timestampIn = rfidPayload.timestamp;
    
                contract.submitTransaction('openCar', carKeyIn, renterIDIn, timestampIn);
                console.log('Transaction has been submitted');

                
            // This line doesn't run until the server responds to the publish
            await client.end();
            // This line doesn't run until the client has disconnected without error
            console.log("Done");
            });
            await client.subscribe("rfidData");
            console.log("Subscribed")
        } catch (e){
            // Do something about it!
            console.log(e.stack);
            process.exit(2);
        }
    }
    
    client.on("connect", run)