class MqttCrystal::Packet

Direct Known Subclasses

Defined in:

mqtt_crystal/packet.cr

Constant Summary

PACKET_TYPES = [nil, Packet::Connect, Packet::Connack, Packet::Publish, Packet::Puback, Packet::Pubrec, Packet::Pubrel, Packet::Pubcomp, Packet::Subscribe, Packet::Suback, Packet::Unsubscribe, Packet::Unsuback, Packet::Pingreq, Packet::Pingresp, Packet::Disconnect, nil]

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new(flags : Array(Bool) = [false, false, false, false], body_length : UInt64 = 0_u64) #

[View source]

Class Method Detail

def self.create_from_header(byte : UInt8) #

[View source]
def self.parse(bytes : Array(UInt8)) : Packet | Nil #

[View source]
def self.slice_it(a : String) : Bytes #

[View source]
def self.slice_it(a : Array(UInt8)) : Bytes #

[View source]

Instance Method Detail

def _extract_string!(buffer : Array(UInt8), index : Int32 = 0) : String #

[View source]
def body_length : UInt64 #

[View source]
def body_length=(body_length : UInt64) #

[View source]
def bytes : Bytes #

[View source]
def check_remaining_length(bytes : Array(UInt8)) : NamedTuple(pos: UInt8, body_length: UInt64) #

[View source]
def concatenate(*args) : Bytes #

[View source]
def decode_short(buffer : Array(UInt8), index : Int32) : UInt16 #

[View source]
def encode_body : Bytes #

[View source]
def encode_header : UInt8 #

[View source]
def encode_short(n : UInt16) : Bytes #

[View source]
def encode_string(str : String) : Bytes #

[View source]
def encode_string(strings : Array(String)) : Bytes #

[View source]
def flags : Array(Bool) #

[View source]
def flags=(flags : Array(Bool)) #

[View source]
def parse_body(buffer : Array(UInt8)) #

[View source]
def slice_it(a : Array(UInt8)) : Bytes #

[View source]
def type_id : Int32 #

[View source]
def validate_flags #

[View source]