const options = { brokerUrl: 'mqtt://localhost:1883'}

const client = new Client(options, Adapter)

const connect = () => {
  return new Promise((resovle, reject) => {
    client.connect((err) => {
      if (err) reject()
      resovle()
    })
  })
}

const run = async () => {
  client.on('connect', (data) => {
    console.log('Connected...', data)
  })
  await connect()

  client.subscribe('test')

  client.on('error', (err) => {
    console.log(err)
  })


  client.on('message', function(topic, message, packet) {
    console.log('Incoming message...', topic, message.toString())
  })
}

(async() => {
  await run()
})()