TcpConnection

An asynchronous TCP connection.

class TcpConnection : StreamConnection {

this(Socket conn);

sizediff_t doSend(void[] buffer);

sizediff_t doReceive(void[] buffer);

void tryNextAddress();

void onError(string reason);

this();

void connect(string host, ushort port);

void connect(AddressInfo[] addresses);

}

Constructors

this this(Socket conn): Undocumented in source.
this this(): Default constructor

Members

Functions

connect void connect(string host, ushort port)
void connect(AddressInfo[] addresses): Start establishing a connection.
doReceive sizediff_t doReceive(void[] buffer): Undocumented in source. Be warned that the author may not have intended to support it.
doSend sizediff_t doSend(void[] buffer): Undocumented in source. Be warned that the author may not have intended to support it.
onError void onError(string reason): Called when an error occurs on the socket.
tryNextAddress void tryNextAddress(): Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From StreamConnection

state ConnectionState state [@property getter]: Get connection state.
doSend sizediff_t doSend(void[] buffer): Undocumented in source.
doReceive sizediff_t doReceive(void[] buffer): Undocumented in source.
outQueue Data[][MAX_PRIORITY + 1] outQueue;: The send buffers.
partiallySent bool[MAX_PRIORITY + 1] partiallySent;: Whether the first item from each queue has been partially sent (and thus can't be cancelled).
updateFlags void updateFlags(): Undocumented in source. Be warned that the author may not have intended to support it.
onReadable void onReadable(): Called when a socket is readable.
onWritable void onWritable(): Called when a socket is writable.
onError void onError(string reason): Called when an error occurs on the socket.
disconnect void disconnect(string reason, DisconnectType type): Close a connection. If there is queued data waiting to be sent, wait until it is sent before disconnecting. The disconnect handler will be called immediately, even when not all data has been flushed yet.
send void send(Data[] data, int priority)
alias send = IConnection.send: Append data to the send buffer.
clearQueue void clearQueue(int priority): Undocumented in source. Be warned that the author may not have intended to support it.
writePending bool writePending [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
queuePresent bool queuePresent(int priority): Undocumented in source. Be warned that the author may not have intended to support it.
handleConnect ConnectHandler handleConnect [@property setter]: Callback for when a connection has been established.
handleReadData ReadDataHandler handleReadData [@property setter]: Callback for incoming data. Data will not be received unless this handler is set.
handleDisconnect DisconnectHandler handleDisconnect [@property setter]: Callback for when a connection was closed.
handleBufferFlushed BufferFlushedHandler handleBufferFlushed [@property setter]: Undocumented in source. Be warned that the author may not have intended to support it.

TcpConnection

Constructors

Members

Functions

Inherited Members

From StreamConnection

Meta

Source