org.asynchttpclient

Class ListenableFuture.CompletedFailure<T>

java.lang.Object

org.asynchttpclient.ListenableFuture.CompletedFailure<T>

All Implemented Interfaces:

Future<T>, ListenableFuture<T>

Enclosing interface:

ListenableFuture<V>

public static class ListenableFuture.CompletedFailure<T>
extends Object
implements ListenableFuture<T>

Nested Class Summary

Nested classes/interfaces inherited from interface org.asynchttpclient.ListenableFuture

ListenableFuture.CompletedFailure<T>

Constructor Summary

Constructors

Constructor and Description
CompletedFailure(String message, Throwable t)
CompletedFailure(Throwable t)

Method Summary

Modifier and Type	Method and Description
void	abort(Throwable t) Abort the current processing, and propagate the Throwable to the AsyncHandler or Future
ListenableFuture<T>	addListener(Runnable listener, Executor exec) Adds a listener and executor to the ListenableFuture.
boolean	cancel(boolean mayInterruptIfRunning)
void	done() Terminate and if there is no exception, mark this Future as done and release the internal lock.
T	get()
T	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
CompletableFuture<T>	toCompletableFuture()
void	touch() Touch the current instance to prevent external service to times out.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CompletedFailure

public CompletedFailure(Throwable t)

CompletedFailure

public CompletedFailure(String message,
                        Throwable t)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

get

public T get()
      throws ExecutionException

Specified by:

get in interface Future<T>

Throws:

ExecutionException

get

public T get(long timeout,
             TimeUnit unit)
      throws ExecutionException

Specified by:

get in interface Future<T>

Throws:

ExecutionException

done

public void done()

Description copied from interface: ListenableFuture

Terminate and if there is no exception, mark this Future as done and release the internal lock.

Specified by:

done in interface ListenableFuture<T>

abort

public void abort(Throwable t)

Description copied from interface: ListenableFuture

Abort the current processing, and propagate the Throwable to the AsyncHandler or Future

Specified by:

abort in interface ListenableFuture<T>

Parameters:

t - the exception

touch

public void touch()

Description copied from interface: ListenableFuture

Touch the current instance to prevent external service to times out.

Specified by:

touch in interface ListenableFuture<T>

addListener

public ListenableFuture<T> addListener(Runnable listener,
                                       Executor exec)

Description copied from interface: ListenableFuture

Adds a listener and executor to the ListenableFuture. The listener will be passed to the executor for execution when the Future's computation is complete.
Executor can be null, in that case executor will be executed in the thread where completion happens.
There is no guaranteed ordering of execution of listeners, they may get called in the order they were added and they may get called out of order, but any listener added through this method is guaranteed to be called once the computation is complete.

Specified by:

addListener in interface ListenableFuture<T>

Parameters:

listener - the listener to run when the computation is complete.

exec - the executor to run the listener in.

Returns:

this Future

toCompletableFuture

public CompletableFuture<T> toCompletableFuture()

Specified by:

toCompletableFuture in interface ListenableFuture<T>