Class MqttWire

Example

const wire = new MqttWire({
  onSend: (data) => socket.write(data),
  onConnect: (connect) => ({
    type: PacketType.CONNACK,
    sessionPresent: false,
    reasonCode: 0x00
  }),
  onPublish: (packet) => console.log(packet.topic, packet.payload),
  onSubscribe: (packet) => ({
    type: PacketType.SUBACK,
    packetId: packet.packetId,
    reasonCodes: packet.subscriptions.map(s => s.options.qos)
  }),
  onDisconnect: () => console.log('client disconnected'),
  onError: (err) => console.error(err)
})

// Receive data from transport
socket.on('data', (chunk) => wire.receive(chunk))

// Publish to client
await wire.publish('topic', payload, { qos: 1 })

// Disconnect client
await wire.disconnect()
Copy