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