Module org.elasticsearch.server
Package org.elasticsearch.common.util.concurrent

Class ListenableFuture<T>

java.lang.Object
org.elasticsearch.action.support.SubscribableListener<T>
org.elasticsearch.common.util.concurrent.ListenableFuture<T>
All Implemented Interfaces:
ActionListener<T>
public final class ListenableFuture<T> extends SubscribableListener<T>
An ActionListener which allows for the result to fan out to a (dynamic) collection of other listeners, added using SubscribableListener.addListener(org.elasticsearch.action.ActionListener<T>). Listeners added before completion are retained until completion; listeners added after completion are completed immediately. Similar to ListenableActionFuture and SubscribableListener except for its handling of exceptions: if this listener is completed exceptionally with a checked exception then it wraps the exception in an UncategorizedExecutionException whose cause is an ExecutionException, whose cause in turn is the checked exception. This matches the behaviour of FutureUtils.get(java.util.concurrent.Future<T>).