AbstractStream

TCP Client

version(Posix)

abstract

class AbstractStream : AbstractSocketChannel , Stream {

SimpleEventHandler disconnectionHandler;

bool _isConnected;

this(Selector loop, AddressFamily family, size_t bufferSize);

bool tryRead();

void onDisconnected();

bool canWriteAgain;

int writeRetryLimit;

void tryWriteAll(ubyte[] data);

size_t tryWrite(ubyte[] data);

void doConnect(Address addr);

void cancelWrite();

void onWriteDone();

WriteBufferQueue _writeQueue;

bool isWriteCancelling;

DataReceivedHandler dataReceivedHandler;

}

Constructors

this this(Selector loop, AddressFamily family, size_t bufferSize): Undocumented in source.

Members

Functions

cancelWrite void cancelWrite(): Undocumented in source. Be warned that the author may not have intended to support it.
doConnect void doConnect(Address addr): Undocumented in source. Be warned that the author may not have intended to support it.
onDisconnected void onDisconnected(): Undocumented in source. Be warned that the author may not have intended to support it.
onWriteDone void onWriteDone(): Undocumented in source. Be warned that the author may not have intended to support it.
tryRead bool tryRead()
tryWrite size_t tryWrite(ubyte[] data): Try to write a block of data.
tryWriteAll void tryWriteAll(ubyte[] data): Warning: It will try the best to write all the data. // TODO: create a examlple for test

Variables

_isConnected bool _isConnected;: Undocumented in source.
_writeQueue WriteBufferQueue _writeQueue;: Undocumented in source.
canWriteAgain bool canWriteAgain;: Undocumented in source.
dataReceivedHandler DataReceivedHandler dataReceivedHandler;: Warning: The received data is stored a inner buffer. For a data safe, you would make a copy of it.
disconnectionHandler SimpleEventHandler disconnectionHandler;: Undocumented in source.
isWriteCancelling bool isWriteCancelling;: Undocumented in source.
writeRetryLimit int writeRetryLimit;: Undocumented in source.

Inherited Members

From AbstractSocketChannel

_family AddressFamily _family;: Undocumented in source.
socket Socket socket [@property setter]: Undocumented in source. Be warned that the author may not have intended to support it.
socket Socket socket [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
__anonymous mixin ChannelSocketOption: Undocumented in source.
setRead void setRead(size_t bytes): Undocumented in source. Be warned that the author may not have intended to support it.
readLen size_t readLen;: Undocumented in source.
start void start(): Undocumented in source.
onWriteDone void onWriteDone(): Undocumented in source. Be warned that the author may not have intended to support it.
_socket Socket _socket;: Undocumented in source.

Meta

Source

See Implementation

kiss event socket posix classes