mqtt ~master (2019-03-27T20:21:48Z)

MqttStreamConnection

mqttd stream

Satisfies the isMqttConnection interface for streams (e.g. TCP) Delegates actually reading or writing data to a templated channel.

@safe
struct MqttStreamConnection (
Channel
) {
import mqttd.server : MqttServer, isMqttConnection;;
import mqttd.stream : MqttStream, isMqttInput;;
this(Channel channel);
void read(ubyte[] bytes);
void send(ubyte[] bytes);
void run(MqttServer!(typeof(this)) server);
bool connected [@property getter];
void disconnect();
}

Constructors

this
this(Channel channel)
Undocumented in source.

Members

Functions

disconnect
void disconnect()
Undocumented in source. Be warned that the author may not have intended to support it.
read
void read(ubyte[] bytes)
Undocumented in source. Be warned that the author may not have intended to support it.
run
void run(MqttServer!(typeof(this)) server)
Undocumented in source. Be warned that the author may not have intended to support it.
send
void send(ubyte[] bytes)
Undocumented in source. Be warned that the author may not have intended to support it.

Properties

connected
bool connected [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

mqttd stream enumsstructs

Page generated by adrdox