StreamWrapper

A wrapper around streams, which do not actually implement the Stream interface (e.g. TCPConnection).

class StreamWrapper : Stream(

T

) if (

isStream!T

) {

this(T stream);

bool empty [@property getter];

ulong leastSize [@property getter];

bool dataAvailableForRead [@property getter];

const(ubyte)[] peek();

size_t read(ubyte[] dst, IOMode mode);

size_t write(ubyte[] bytes, IOMode mode);

void flush();

void finalize();

}

Constructors

this this(): Undocumented in source.
this this(T stream): Undocumented in source.

Members

Functions

finalize void finalize(): Undocumented in source. Be warned that the author may not have intended to support it.
flush void flush(): Undocumented in source. Be warned that the author may not have intended to support it.
peek const(ubyte)[] peek(): Undocumented in source. Be warned that the author may not have intended to support it.
read size_t read(ubyte[] dst, IOMode mode): Undocumented in source. Be warned that the author may not have intended to support it.
write size_t write(ubyte[] bytes, IOMode mode): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

dataAvailableForRead bool dataAvailableForRead [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
empty bool empty [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
leastSize ulong leastSize [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

mqttd stream_wrapper classes

StreamWrapper

structs

blocking