public final class UDPNIOAsyncQueueReader extends AbstractNIOAsyncQueueReader
AsyncQueueReader
implementation, based on
the Java NIOAsyncQueue.AsyncResult
DEFAULT_BUFFER_SIZE, defaultBufferSize, transport
COMPLETE_EVENT, INCOMPLETE_EVENT, READ_EVENT
EXPECTING_MORE_OPTION
Constructor and Description |
---|
UDPNIOAsyncQueueReader(NIOTransport transport) |
Modifier and Type | Method and Description |
---|---|
protected void |
addRecord(Connection connection,
Buffer buffer,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
protected void |
onReadyToRead(Connection connection) |
protected int |
read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
close, doRead, isReady, onClose, onReadFailure, processAsync, read
read, read, read
public UDPNIOAsyncQueueReader(NIOTransport transport)
protected int read0(Connection connection, Buffer buffer, ReadResult<Buffer,SocketAddress> currentResult) throws IOException
read0
in class AbstractNIOAsyncQueueReader
IOException
protected void addRecord(Connection connection, Buffer buffer, CompletionHandler completionHandler, Interceptor<ReadResult> interceptor)
protected void onReadyToRead(Connection connection) throws IOException
onReadyToRead
in class AbstractNIOAsyncQueueReader
IOException
Copyright © 2015 Oracle Corporation. All rights reserved.