ConnectFuture
, IoFuture
public class DefaultConnectFuture extends DefaultIoFuture implements ConnectFuture
ConnectFuture
.Constructor | Description |
---|---|
DefaultConnectFuture() |
Creates a new instance.
|
DefaultConnectFuture(java.lang.Object lock) |
Creates a new instance which uses the specified object as a lock.
|
Modifier and Type | Method | Description |
---|---|---|
IoSession |
getSession() |
Returns the
IoSession which is associated with this future. |
boolean |
isConnected() |
Returns true if the connect operation is finished successfully.
|
static ConnectFuture |
newFailedFuture(java.lang.Throwable exception) |
Returns a new
ConnectFuture which is already marked as 'failed to connect'. |
void |
setException(java.lang.Throwable exception) |
Sets the exception caught due to connection failure and notifies all
threads waiting for this future.
|
void |
setSession(IoSession session) |
Sets the newly connected session and notifies all threads waiting for
this future.
|
addListener, getLock, getValue, isReady, join, join, removeListener, setValue
addListener, getLock, isReady, join, join, removeListener
public DefaultConnectFuture()
public DefaultConnectFuture(java.lang.Object lock)
public static ConnectFuture newFailedFuture(java.lang.Throwable exception)
ConnectFuture
which is already marked as 'failed to connect'.public IoSession getSession() throws RuntimeIOException
IoFuture
IoSession
which is associated with this future.getSession
in interface ConnectFuture
getSession
in interface IoFuture
getSession
in class DefaultIoFuture
RuntimeIOException
- if connection attempt failed by an exceptionpublic boolean isConnected()
ConnectFuture
isConnected
in interface ConnectFuture
public void setSession(IoSession session)
ConnectFuture
setSession
in interface ConnectFuture
public void setException(java.lang.Throwable exception)
ConnectFuture
setException
in interface ConnectFuture