class MiniMqtt::SubscribePacket
Attributes
packet_id[RW]
topics[RW]
Public Class Methods
new(params = {})
click to toggle source
# File lib/mini_mqtt/subscribe_packet.rb, line 6 def initialize params = {} @topics = params[:topics] end
Public Instance Methods
build_payload()
click to toggle source
# File lib/mini_mqtt/subscribe_packet.rb, line 19 def build_payload @topics.map do |topic, qos| mqtt_utf8_encode(topic) + uchar(qos) end.join end
build_variable_header()
click to toggle source
# File lib/mini_mqtt/subscribe_packet.rb, line 14 def build_variable_header @packet_id ||= new_packet_id ushort @packet_id end
flags()
click to toggle source
# File lib/mini_mqtt/subscribe_packet.rb, line 10 def flags 0b0010 end