-
mqtt.subscribe(pkt)
-- Encode and send an MQTT subscribe packet.mqtt.subscribe(topic, ex)
-- alias formqtt.subscribe({topics: [topic], ...ex})
mqtt.subscribe(topic_list, ex)
-- alias formqtt.subscribe({topics: [... topic_list], ...ex})
mqtt.sub
-- alias formqtt.subscribe
variants
Returns a
Promise<[suback pkt, error]>
in the style of an Option / Maybe monad.See
u8-mqtt-packet/docs/mqtt_codec_subscribe.md
for MQTT packet encoding details
See ./pkt-router.md for documentation on packet routing and handlers.
-
mqtt.unsubscribe(pkt)
-- Encode and send an MQTT unsubscribe packet.mqtt.unsub
-- alias formqtt.unsubscribe
mqtt.unsubscribe(topic, ex)
-- alias formqtt.unsubscribe({topics: [topic], ...ex})
mqtt.unsub(topic, ex)
-- alias formqtt.unsubscribe({topics: [topic], ...ex})
mqtt.unsubscribe(topic_list, ex)
-- alias formqtt.unsubscribe({topics: [... topic_list], ...ex})
mqtt.unsub(topic_list, ex)
-- alias formqtt.unsubscribe({topics: [... topic_list], ...ex})
Returns a
Promise<[unsuback pkt, error]>
in the style of an Option / Maybe monad.See
u8-mqtt-packet/docs/mqtt_codec_unsubscribe.md
for MQTT packet encoding details