SocketReceiveStream

Undocumented in source.

class SocketReceiveStream : IReceiveStream {

this(Socket socket);

Socket socket;

ubyte[4096] buffer;

int bufferLength;

int bufferPos;

ptrdiff_t receiveSocket(ubyte[] buffer);

void loadMore();

void readExact(ubyte[] dst);

immutable(ubyte)[] readUntilNull();

}

Constructors

this this(Socket socket): Undocumented in source.

Members

Functions

loadMore void loadMore(): Loads more data after bufferPos if there is space, otherwise load before bufferPos, indicating data is wrapping around.
readExact void readExact(ubyte[] dst): Undocumented in source. Be warned that the author may not have intended to support it.
readUntilNull immutable(ubyte)[] readUntilNull(): Undocumented in source. Be warned that the author may not have intended to support it.
receiveSocket ptrdiff_t receiveSocket(ubyte[] buffer): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

buffer ubyte[4096] buffer;: Undocumented in source.
bufferLength int bufferLength;: Undocumented in source.
bufferPos int bufferPos;: Undocumented in source.
socket Socket socket;: Undocumented in source.

Inherited Members

From IReceiveStream

readReply OP_REPLY readReply(): Undocumented in source. Be warned that the author may not have intended to support it.
readBson document readBson(): Undocumented in source. Be warned that the author may not have intended to support it.
readBsonValue bson_value readBsonValue(int remaining): Undocumented in source. Be warned that the author may not have intended to support it.
readByte ubyte readByte(): Undocumented in source. Be warned that the author may not have intended to support it.
readInt int readInt(): Undocumented in source. Be warned that the author may not have intended to support it.
readLong long readLong(): Undocumented in source. Be warned that the author may not have intended to support it.
readDouble double readDouble(): Undocumented in source. Be warned that the author may not have intended to support it.
readZeroTerminatedChars string readZeroTerminatedChars(): Undocumented in source. Be warned that the author may not have intended to support it.
readCharsWithLengthPrefix string readCharsWithLengthPrefix(): Undocumented in source. Be warned that the author may not have intended to support it.
readBytes immutable(ubyte)[] readBytes(size_t length): Reads exactly the amount of bytes specified and returns a newly allocated buffer containing the data.
readSmall ubyte[n] readSmall(): Reads a small number of bytes into a stack allocated array. Convenience function calling readExact.
readExact void readExact(ubyte[] buffer): Reads exactly the expected length into the given buffer argument.
readUntilNull immutable(ubyte)[] readUntilNull(): Reads until a 0 byte and returns all data before it as newly allocated buffer containing the data.

SocketReceiveStream

Constructors

Members

Functions

Variables

Inherited Members

From IReceiveStream

Meta

Source