MqttCrystal::Packet

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]

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

create_from_header(byte : UInt8)

parse(bytes : Array(UInt8)) : Packet | Nil

slice_it(a : String) : Bytes

slice_it(a : Array(UInt8)) : Bytes

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

body_length=(body_length : UInt64)

check_remaining_length(bytes : Array(UInt8)) : NamedTuple(pos: UInt8, body_length: UInt64)

concatenate(*args) : Bytes

decode_short(buffer : Array(UInt8), index : Int32) : UInt16

encode_short(n : UInt16) : Bytes

encode_string(str : String) : Bytes

encode_string(strings : Array(String)) : Bytes

flags=(flags : Array(Bool))

parse_body(buffer : Array(UInt8))

slice_it(a : Array(UInt8)) : Bytes