Package org.apache.sshd.common.channel
Class ChannelAsyncInputStream.IoReadFutureImpl
- java.lang.Object
-
- org.apache.sshd.common.util.logging.AbstractLoggingBean
-
- org.apache.sshd.common.future.AbstractSshFuture<T>
-
- org.apache.sshd.common.future.DefaultSshFuture<T>
-
- org.apache.sshd.common.future.DefaultVerifiableSshFuture<IoReadFuture>
-
- org.apache.sshd.common.channel.ChannelAsyncInputStream.IoReadFutureImpl
-
- All Implemented Interfaces:
SshFuture<IoReadFuture>,VerifiableFuture<IoReadFuture>,WaitableFuture,IoReadFuture
- Enclosing class:
- ChannelAsyncInputStream
public static class ChannelAsyncInputStream.IoReadFutureImpl extends DefaultVerifiableSshFuture<IoReadFuture> implements IoReadFuture
-
-
Field Summary
Fields Modifier and Type Field Description private Bufferbuffer-
Fields inherited from class org.apache.sshd.common.future.AbstractSshFuture
CANCELED
-
Fields inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean
log
-
-
Constructor Summary
Constructors Constructor Description IoReadFutureImpl(java.lang.Object id, Buffer buffer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BuffergetBuffer()java.lang.ThrowablegetException()Returns the cause of the read failure.intgetRead()IoReadFutureverify(long timeoutMillis)Wait and verify that the operation was successful-
Methods inherited from class org.apache.sshd.common.future.DefaultSshFuture
addListener, await0, cancel, getNumRegisteredListeners, getValue, isCanceled, isDone, notifyListeners, removeListener, setValue, toString
-
Methods inherited from class org.apache.sshd.common.future.AbstractSshFuture
asListener, asT, await, awaitUninterruptibly, formatExceptionMessage, getId, notifyListener, verifyResult
-
Methods inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean
debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.sshd.common.future.SshFuture
addListener, removeListener
-
Methods inherited from interface org.apache.sshd.common.future.VerifiableFuture
verify, verify, verify
-
Methods inherited from interface org.apache.sshd.common.future.WaitableFuture
await, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, getId, isDone
-
-
-
-
Field Detail
-
buffer
private final Buffer buffer
-
-
Constructor Detail
-
IoReadFutureImpl
public IoReadFutureImpl(java.lang.Object id, Buffer buffer)
-
-
Method Detail
-
getBuffer
public Buffer getBuffer()
- Specified by:
getBufferin interfaceIoReadFuture
-
verify
public IoReadFuture verify(long timeoutMillis) throws java.io.IOException
Description copied from interface:VerifiableFutureWait and verify that the operation was successful- Specified by:
verifyin interfaceVerifiableFuture<IoReadFuture>- Parameters:
timeoutMillis- Wait timeout in milliseconds- Returns:
- The (same) future instance
- Throws:
java.io.IOException- If failed to verify successfully on time
-
getRead
public int getRead()
- Specified by:
getReadin interfaceIoReadFuture
-
getException
public java.lang.Throwable getException()
Description copied from interface:IoReadFutureReturns the cause of the read failure.- Specified by:
getExceptionin interfaceIoReadFuture- Returns:
nullif the read operation is not finished yet, or if the read attempt is successful (useWaitableFuture.isDone()to distinguish between the two).
-
-