MQTT::Protocol::IO

new(io : ::IO, max_packet_size : UInt32 | Nil = nil, byte_format = ::IO::ByteFormat::NetworkEndian)

read_bytes(len : Int | Nil = nil)

read_string(len : UInt16 | Nil = nil)

write(packet : Packet)

write_byte(b : UInt8)

write_bytes(bytes : Bytes)

write_bytes(bytes : Nil)

write_bytes_raw(bytes : Bytes)

write_int(int : Int)

write_packet(packet : Packet)

write_remaining_length(length)

write_string(str : String)

write_string(str : Nil)

method_missing(call)