class MQTT::Client::Reader

Defined in:

mqtt-client/connection/reader.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(socket : IO, acks : Channel(UInt16), writer : Writer, keepalive : UInt16) #

[View source]

Instance Method Detail

def close #

[View source]
def expect_connack(socket = @socket) #

[View source]
def messages : Channel(MQTT::Client::Reader::Message) #

[View source]
def run(socket = @socket) #

http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html#_Toc398718021


[View source]