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.

AbstractStream

Constructors

Members

Functions

Manifest constants

Variables

Inherited Members

From AbstractSocketChannel

Meta

Source