|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface AsyncQueueReader
Method Summary | |
---|---|
void |
close()
Close AsyncQueueReader and release its resources |
AsyncQueue.AsyncQueueEntry |
getAsyncQueue(SelectionKey key)
Gets ready asynchronous queue elements to be read from the SelectableChannel , associated with the
given SelectionKey |
boolean |
isReady(SelectionKey key)
Checks whether AsyncQueueReader is registered
for the SelectableChannel , associated with the given
SelectionKey |
void |
onClose(SelectableChannel channel)
Callback method, which should be called by SelectorHandler to
notify, that given SelectableChannel is going to be closed, so
related data could be released from
AsyncQueueReader |
void |
onRead(SelectionKey key)
Callback method, which should be called by SelectorHandler to
notify, that SelectableChannel , associated with the given
SelectableChannel has ready data for reading. |
Future<AsyncQueueReadUnit> |
read(SelectionKey key,
ByteBuffer buffer,
AsyncReadCallbackHandler callbackHandler)
|
Future<AsyncQueueReadUnit> |
read(SelectionKey key,
ByteBuffer buffer,
AsyncReadCallbackHandler callbackHandler,
AsyncReadCondition condition)
|
Future<AsyncQueueReadUnit> |
read(SelectionKey key,
ByteBuffer buffer,
AsyncReadCallbackHandler callbackHandler,
AsyncReadCondition condition,
AsyncQueueDataProcessor readPostProcessor)
|
Method Detail |
---|
Future<AsyncQueueReadUnit> read(SelectionKey key, ByteBuffer buffer, AsyncReadCallbackHandler callbackHandler) throws IOException
IOException
Future<AsyncQueueReadUnit> read(SelectionKey key, ByteBuffer buffer, AsyncReadCallbackHandler callbackHandler, AsyncReadCondition condition) throws IOException
IOException
Future<AsyncQueueReadUnit> read(SelectionKey key, ByteBuffer buffer, AsyncReadCallbackHandler callbackHandler, AsyncReadCondition condition, AsyncQueueDataProcessor readPostProcessor) throws IOException
IOException
boolean isReady(SelectionKey key)
AsyncQueueReader
is registered
for the SelectableChannel
, associated with the given
SelectionKey
key
- SelectionKey
associated with SelectableChannel
AsyncQueue.AsyncQueueEntry getAsyncQueue(SelectionKey key)
SelectableChannel
, associated with the
given SelectionKey
key
- SelectionKey
associated with SelectableChannel
SelectableChannel
, associated with the
given SelectionKey
/void onRead(SelectionKey key) throws IOException
SelectorHandler
to
notify, that SelectableChannel
, associated with the given
SelectableChannel
has ready data for reading.
key
- SelectionKey
associated with SelectableChannel
java.io.IOException
IOException
void onClose(SelectableChannel channel)
SelectorHandler
to
notify, that given SelectableChannel
is going to be closed, so
related data could be released from
AsyncQueueReader
{@link
- SelectableChannel}
IOException
void close()
AsyncQueueReader
and release its resources
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |