AsyncQueueReader implementation, based on the Java NIO
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| protected void | addRecord(Connection<L> connection, Buffer buffer, CompletionHandler<E> completionHandler, Interceptor<ReadResult<K, L>> interceptor)
|
| protected void | onReadyToRead(Connection<L> connection)
Implements abstract org.
|
| protected int | read0(Connection<L> connection, Buffer buffer, ReadResult<Buffer, SocketAddress> currentResult)
Implements abstract org.
|
| UDPNIOAsyncQueueReader | back to summary |
|---|---|
| public UDPNIOAsyncQueueReader(NIOTransport transport) | |
| addRecord | back to summary |
|---|---|
| protected void addRecord(Connection<L> connection, Buffer buffer, CompletionHandler<E> completionHandler, Interceptor<ReadResult<K, L>> interceptor) | |
| onReadyToRead | back to summary |
|---|---|
| protected void onReadyToRead(Connection<L> connection) throws IOException Implements abstract org.
| |
| read0 | back to summary |
|---|---|
| protected int read0(Connection<L> connection, Buffer buffer, ReadResult<Buffer, SocketAddress> currentResult) throws IOException Implements abstract org.
| |