public final class AsyncReadQueueRecord extends AsyncQueueRecord<ReadResult>
AsyncQueue
read element unitModifier and Type | Field and Description |
---|---|
protected Interceptor |
interceptor |
completionHandler, connection, currentResult, isRecycled, message, recycleTrack
Modifier and Type | Method and Description |
---|---|
static AsyncReadQueueRecord |
create(Connection connection,
Buffer message,
ReadResult currentResult,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
Interceptor |
getInterceptor() |
boolean |
isFinished() |
void |
notifyComplete() |
void |
recycle() |
protected void |
reset() |
checkRecycled, getConnection, getCurrentResult, getMessage, notifyFailure, notifyIncomplete, set, setMessage
protected Interceptor interceptor
public static AsyncReadQueueRecord create(Connection connection, Buffer message, ReadResult currentResult, CompletionHandler completionHandler, Interceptor<ReadResult> interceptor)
public final Interceptor getInterceptor()
public final void notifyComplete()
public boolean isFinished()
protected final void reset()
public void recycle()
Copyright © 2014 Oracle Corporation. All rights reserved.