public final class TCPNIOAsyncQueueWriter extends AbstractNIOAsyncQueueWriter
AsyncQueueWriter
implementation, based on
the Java NIOWriter.Reentrant
AsyncQueue.AsyncResult
maxPendingBytes, maxWriteReentrants, transport
AUTO_SIZE, UNLIMITED_SIZE
EXPECTING_MORE_OPTION
Constructor and Description |
---|
TCPNIOAsyncQueueWriter(NIOTransport transport) |
Modifier and Type | Method and Description |
---|---|
protected AsyncWriteQueueRecord |
aggregate(TaskQueue<AsyncWriteQueueRecord> writeTaskQueue)
Aggregates records in a queue to be written as one chunk.
|
protected void |
onReadyToWrite(NIOConnection connection) |
protected RecordWriteResult |
write0(NIOConnection connection,
AsyncWriteQueueRecord queueRecord) |
protected long |
write0(NIOConnection connection,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
canWrite, canWrite, close, createRecord, getMaxPendingBytesPerConnection, isAllowDirectWrite, isReady, notifyWritePossible, notifyWritePossible, onClose, onWriteFailure, processAsync, setAllowDirectWrite, setMaxPendingBytesPerConnection, write, write, write
write, write, write, write
public TCPNIOAsyncQueueWriter(NIOTransport transport)
protected RecordWriteResult write0(NIOConnection connection, AsyncWriteQueueRecord queueRecord) throws IOException
write0
in class AbstractNIOAsyncQueueWriter
IOException
protected long write0(NIOConnection connection, WritableMessage message, WriteResult<WritableMessage,SocketAddress> currentResult) throws IOException
IOException
protected final void onReadyToWrite(NIOConnection connection) throws IOException
onReadyToWrite
in class AbstractNIOAsyncQueueWriter
IOException
protected AsyncWriteQueueRecord aggregate(TaskQueue<AsyncWriteQueueRecord> writeTaskQueue)
aggregate
in class AbstractNIOAsyncQueueWriter
Copyright © 2015 Oracle Corporation. All rights reserved.