AbstractStream

TCP Peer

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.

Manifest constants

BufferSize
enum BufferSize;
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.

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.

Meta