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(InputStream input, void delegate() @(safe) callback);

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 deprecated this(InputStream input, void delegate() @(safe) callback): Undocumented in source.
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.

Inherited Members

From InputStream

empty bool empty [@property getter]: Returns true iff the end of the input stream has been reached.
leastSize ulong leastSize [@property getter]: (Scheduled for deprecation) Returns the maximum number of bytes that are known to remain in this stream until the end is reached.
dataAvailableForRead bool dataAvailableForRead [@property getter]: (Scheduled for deprecation) Queries if there is data available for immediate, non-blocking read.
peek const(ubyte)[] peek(): Returns a temporary reference to the data that is currently buffered.
read size_t read(ubyte[] dst, IOMode )
void read(ubyte[] dst): Fills the preallocated array 'bytes' with data from the stream.