EndCallbackInputStream

Wraps an input stream and calls the given delegate once the stream is empty.

Note that this function will potentially block after each read operation to see if the end has already been reached - this may take as long until either new data has arrived or until the connection was closed.

The stream will also guarantee that the inner stream is not used after it has been determined to be empty. It can thus be safely deleted once the callback is invoked.

class EndCallbackInputStream : InputStream {

this(InterfaceProxy!InputStream input, void delegate() @(safe) callback, bool dummy);

bool empty [@property getter];

ulong leastSize [@property getter];

bool dataAvailableForRead [@property getter];

const(ubyte)[] peek();

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

alias read = InputStream.read;

}

Constructors

this this(InterfaceProxy!InputStream input, void delegate() @(safe) callback, bool dummy): private

Members

Aliases

read alias read = InputStream.read: Undocumented in source.

Functions

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.

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.