public static class ChannelAsyncInputStream.IoReadFutureImpl extends DefaultVerifiableSshFuture<IoReadFuture> implements IoReadFuture
CANCELED
log
Constructor and Description |
---|
IoReadFutureImpl(Object id,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
Buffer |
getBuffer()
Retrieves the buffer data was read into.
|
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, toString
asListener, asT, await, awaitUninterruptibly, formatExceptionMessage, getId, notifyListener, verifyResult
debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
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
public Buffer getBuffer()
IoReadFuture
getBuffer
in interface IoReadFuture
null
if WaitableFuture.isDone()
== false
public IoReadFuture verify(long timeoutMillis) throws IOException
VerifiableFuture
verify
in interface VerifiableFuture<IoReadFuture>
timeoutMillis
- Wait timeout in millisecondsIOException
- If failed to verify successfully on timepublic int getRead()
IoReadFuture
getRead
in interface IoReadFuture
WaitableFuture.isDone()
== false
)public Throwable getException()
IoReadFuture
EOFException
indicates that nothing was read because
the source of the read is exhausted.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).Copyright © 2008–2024 The Apache Software Foundation. All rights reserved.