AbstractStream

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.

checkAllWriteDone

bool checkAllWriteDone()

Undocumented in source. Be warned that the author may not have intended to support it.

doClose

void doClose()

Undocumented in source. Be warned that the author may not have intended to support it.

doConnect

bool doConnect(Address addr)

Undocumented in source. Be warned that the author may not have intended to support it.

getDataReceivedHandler

DataReceivedHandler getDataReceivedHandler()

Undocumented in source. Be warned that the author may not have intended to support it.

initializeWriteQueue

void initializeWriteQueue()

Undocumented in source. Be warned that the author may not have intended to support it.

isClient

bool isClient()

Undocumented in source.

isConnected

bool isConnected()

Undocumented in source.

isWriteCancelling

bool isWriteCancelling()

Undocumented in source. Be warned that the author may not have intended to support it.

onDisconnected

void onDisconnected()

Undocumented in source.

onWrite

void onWrite()

Should be thread-safe.

resetWriteStatus

void resetWriteStatus()

Undocumented in source. Be warned that the author may not have intended to support it.

tryRead

bool tryRead()

tryWrite

ptrdiff_t tryWrite(const(ubyte)[] data)

Try to write a block of data.

Variables

_family

AddressFamily _family;

Undocumented in source.

_isWriteCancelling

bool _isWriteCancelling;

Undocumented in source.

_writeQueue

WritingBufferQueue _writeQueue;

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.

dataWriteDoneHandler

SimpleActionHandler dataWriteDoneHandler;

Undocumented in source.

disconnectionHandler

SimpleEventHandler disconnectionHandler;

Undocumented in source.

Inherited Members

From AbstractSocketChannel

_isWritting

bool _isWritting;

Undocumented in source.

isBusy

bool isBusy()

Undocumented in source. Be warned that the author may not have intended to support it.

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.

_socket

Socket _socket;

Undocumented in source.

close

void close()

Undocumented in source. Be warned that the author may not have intended to support it.

getOption

int getOption(SocketOptionLevel level, SocketOption option, void[] result)

Get a socket option.

getOption

int getOption(SocketOptionLevel level, SocketOption option, int32_t result)

Common case of getting integer and boolean options.

getOption

int getOption(SocketOptionLevel level, SocketOption option, Linger result)

Get the linger option.

getOption

void getOption(SocketOptionLevel level, SocketOption option, Duration result)

Get a timeout (duration) option.

setOption

void setOption(SocketOptionLevel level, SocketOption option, void[] value)

Set a socket option.

setOption

void setOption(SocketOptionLevel level, SocketOption option, int32_t value)

Common case for setting integer and boolean options.

setOption

void setOption(SocketOptionLevel level, SocketOption option, Linger value)

Set the linger option.

setOption

void setOption(SocketOptionLevel level, SocketOption option, Duration value)

Undocumented in source. Be warned that the author may not have intended to support it.

remoteAddress

Address remoteAddress [@property getter]

Undocumented in source. Be warned that the author may not have intended to support it.

_remoteAddress

Address _remoteAddress;

Undocumented in source.

localAddress

Address localAddress [@property getter]

Undocumented in source. Be warned that the author may not have intended to support it.

_localAddress

Address _localAddress;

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.

• AbstractStream