Constructor and Description |
---|
FutureProxy(Socket socket,
T proxyiedFuture) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel(boolean mayInterruptIfRunning) |
void |
close()
Close the underlying
Socket |
void |
done()
Mark this instance as done.
|
Future |
finishOrThrowException()
Mark the future done.
|
Future |
fire(Object data)
Send data to the remote Server.
|
Socket |
get() |
Socket |
get(long timeout,
TimeUnit unit) |
Future |
ioException(IOException t)
If an exception occurs, the
Transport will set it using this method. |
boolean |
isCancelled() |
boolean |
isDone() |
public Future fire(Object data) throws IOException
Future
data
- the message to fireFuture
IOException
public Future finishOrThrowException() throws IOException
Future
Future
IOException
public Future ioException(IOException t)
Future
Transport
will set it using this method. An application can also
use that method to interrupt a blocking Socket.open(Request)
operation. This operation
must unlock the current blocked thread.t
- a IOException
Future
public void done()
Future
public boolean cancel(boolean mayInterruptIfRunning)
public boolean isCancelled()
isCancelled
in interface Future<Socket>
public Socket get() throws InterruptedException, ExecutionException
get
in interface Future<Socket>
InterruptedException
ExecutionException
public Socket get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
get
in interface Future<Socket>
InterruptedException
ExecutionException
TimeoutException
Copyright © 2015. All Rights Reserved.