public static class ChannelAsyncInputStream.IoReadFutureImpl extends DefaultVerifiableSshFuture<IoReadFuture> implements IoReadFuture
| Modifier and Type | Field and Description |
|---|---|
(package private) Buffer |
buffer |
CANCELEDlog| Constructor and Description |
|---|
IoReadFutureImpl(java.lang.Object id,
Buffer buffer) |
| Modifier and Type | Method and Description |
|---|---|
Buffer |
getBuffer()
Retrieves the buffer data was read into.
|
java.lang.Throwable |
getException()
Returns the cause of the read failure.
|
int |
getRead()
Retrieves the number of bytes read.
|
IoReadFuture |
verify(long timeoutMillis)
Wait and verify that the operation was successful
|
addListener, await0, cancel, getNumRegisteredListeners, getValue, isCanceled, isDone, notifyListeners, removeListener, setValue, toStringasListener, asT, await, awaitUninterruptibly, formatExceptionMessage, getId, notifyListener, verifyResultdebug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warnclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddListener, removeListenerawait, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, getId, isDoneverify, verify, verifyfinal Buffer buffer
public IoReadFutureImpl(java.lang.Object id,
Buffer buffer)
public Buffer getBuffer()
IoReadFuturegetBuffer in interface IoReadFuturenull if WaitableFuture.isDone() == falsepublic IoReadFuture verify(long timeoutMillis) throws java.io.IOException
VerifiableFutureverify in interface VerifiableFuture<IoReadFuture>timeoutMillis - Wait timeout in millisecondsjava.io.IOException - If failed to verify successfully on timepublic int getRead()
IoReadFuturegetRead in interface IoReadFutureWaitableFuture.isDone() == false)public java.lang.Throwable getException()
IoReadFutureEOFException indicates that nothing was read because
the source of the read is exhausted.getException in interface IoReadFuturenull if the read operation is not finished yet, or if the read attempt is successful (use
WaitableFuture.isDone() to distinguish between the two).