public static class ChannelAsyncInputStream.IoReadFutureImpl extends DefaultVerifiableSshFuture<IoReadFuture> implements IoReadFuture
Modifier and Type | Field and Description |
---|---|
private Buffer |
buffer |
CANCELED, debugEnabled, traceEnabled
log
Constructor and Description |
---|
IoReadFutureImpl(java.lang.Object id,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
Buffer |
getBuffer() |
java.lang.Throwable |
getException()
Returns the cause of the read failure.
|
int |
getRead() |
IoReadFuture |
verify(long timeoutMillis)
Wait and verify that the operation was successful
|
addListener, await0, cancel, getNumRegisteredListeners, getValue, isCanceled, isDone, notifyListeners, removeListener, setValue, toString
asListener, asT, await, awaitUninterruptibly, formatExceptionMessage, getId, notifyListener, verifyResult
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addListener, removeListener
await, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, getId, isDone
verify, verify, verify
private final Buffer buffer
public IoReadFutureImpl(java.lang.Object id, Buffer buffer)
public Buffer getBuffer()
getBuffer
in interface IoReadFuture
public IoReadFuture verify(long timeoutMillis) throws java.io.IOException
VerifiableFuture
verify
in interface VerifiableFuture<IoReadFuture>
timeoutMillis
- Wait timeout in millisecondsjava.io.IOException
- If failed to verify successfully on timepublic int getRead()
getRead
in interface IoReadFuture
public java.lang.Throwable getException()
IoReadFuture
getException
in interface IoReadFuture
null
if the read operation is not finished yet, or if the read attempt is successful (use
WaitableFuture.isDone()
to distinguish between the two).