MqttStream

Abstracts a stream protocol such as TCP so that we can get discrete MQTT messages out of it.

@safe

struct MqttStream {

}

Constructors

bufferSize auto bufferSize(): Undocumented in source. Be warned that the author may not have intended to support it.
handleMessages void handleMessages(MqttServer!T server, T connection): Undocumented in source. Be warned that the author may not have intended to support it.
hasMessages bool hasMessages(): Undocumented in source. Be warned that the author may not have intended to support it.
opOpAssign void opOpAssign(ubyte[] bytes): Undocumented in source. Be warned that the author may not have intended to support it.
popNextMessageBytes const(ubyte)[] popNextMessageBytes(): Undocumented in source. Be warned that the author may not have intended to support it.
read void read(T input, size_t size): Undocumented in source. Be warned that the author may not have intended to support it.