class MiniMqtt::Packet
Public Class Methods
get_packet_class(packet_type_id)
click to toggle source
# File lib/mini_mqtt/packet.rb, line 28 def self.get_packet_class packet_type_id @@packet_classes[packet_type_id] end
packet_type_id()
click to toggle source
# File lib/mini_mqtt/packet.rb, line 24 def self.packet_type_id @packet_type_id end
Private Class Methods
register_packet_type(packet_type_id)
click to toggle source
# File lib/mini_mqtt/packet.rb, line 34 def self.register_packet_type packet_type_id @packet_type_id = packet_type_id @@packet_classes[packet_type_id] = self end
Public Instance Methods
decode(stream, flags = 0)
click to toggle source
# File lib/mini_mqtt/packet.rb, line 8 def decode stream, flags = 0 @stream = stream handle_flags flags read_variable_header read_payload self end
encode()
click to toggle source
# File lib/mini_mqtt/packet.rb, line 16 def encode build_variable_header + build_payload end
flags()
click to toggle source
# File lib/mini_mqtt/packet.rb, line 20 def flags 0b000 end
Private Instance Methods
build_payload()
click to toggle source
# File lib/mini_mqtt/packet.rb, line 58 def build_payload "" end
build_variable_header()
click to toggle source
# File lib/mini_mqtt/packet.rb, line 54 def build_variable_header "" end
handle_flags(flags)
click to toggle source
# File lib/mini_mqtt/packet.rb, line 51 def handle_flags flags end
new_packet_id()
click to toggle source
# File lib/mini_mqtt/packet.rb, line 39 def new_packet_id @@last_packet_id += 1 @@last_packet_id %= 65535 1 + @@last_packet_id end
read_payload()
click to toggle source
# File lib/mini_mqtt/packet.rb, line 48 def read_payload end
read_variable_header()
click to toggle source
# File lib/mini_mqtt/packet.rb, line 45 def read_variable_header end