AbstractStream

Constructors

this

this(Selector loop, AddressFamily family, size_t bufferSize)

Undocumented in source.

Members

Functions

beginRead

void beginRead()

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

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.

doConnect

bool doConnect(Address addr)

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

doRead

void doRead()

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.

onClose

void onClose()

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

onDisconnected

void onDisconnected()

Undocumented in source.

onRead

void onRead()

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

onWrite

void onWrite()

Should be thread-safe.

onWriteDone

void onWriteDone(size_t nBytes)

* Called by selector after data sent * Note: It's only for IOCP selector:

resetWriteStatus

void resetWriteStatus()

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

tryWrite

size_t tryWrite(ubyte[] data)

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

Mixins

__anonymous

mixin CheckIocpError

Undocumented in source.

Variables

_bufferForRead

ByteBuffer _bufferForRead;

Undocumented in source.

_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.

Mixed In Members

From mixin CheckIocpError

checkErro

void checkErro(int ret, int erro)

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

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