java.lang.Object

org.elasticsearch.action.support.PlainListenableActionFuture<T>

All Implemented Interfaces:: java.util.concurrent.Future<T>, ActionFuture<T>, ActionListener<T>, ListenableActionFuture<T>

public class PlainListenableActionFuture<T>
extends AdapterActionFuture<T,T>
implements ListenableActionFuture<T>

Method Summary

Modifier and Type	Method	Description
`void`	`addListener(ActionListener<T> listener)`	Add an action listener to be invoked when a response has received.
`protected T`	`convert(T listenerResponse)`
`protected void`	`done()`
`static <T> PlainListenableActionFuture<T>`	`newDispatchingListenableFuture(ThreadPool threadPool)`	This method returns a listenable future.
`static <T> PlainListenableActionFuture<T>`	`newListenableFuture()`	This method returns a listenable future.

actionGet, actionGet, actionGet, actionGet, actionGet, onFailure, onResponse

blockingAllowed, cancel, get, get, interruptTask, isCancelled, isDone, set, setException

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

actionGet, actionGet, actionGet, actionGet, actionGet

cancel, get, get, isCancelled, isDone

Constructor Details
- PlainListenableActionFuture
  
  protected PlainListenableActionFuture()
Method Details
- newListenableFuture
  
  public static <T> PlainListenableActionFuture<T> newListenableFuture()
  
  This method returns a listenable future. The listeners will be called on completion of the future. The listeners will be executed by the same thread that completes the future.
  
  Type Parameters:
  
  T - the result of the future
  
  Returns:
  
  a listenable future
- newDispatchingListenableFuture
  
  public static <T> PlainListenableActionFuture<T> newDispatchingListenableFuture(ThreadPool threadPool)
  
  This method returns a listenable future. The listeners will be called on completion of the future. The listeners will be executed on the LISTENER thread pool.
  
  Type Parameters:
  
  T - the result of the future
  
  Parameters:
  
  threadPool - the thread pool used to execute listeners
  
  Returns:
  
  a listenable future
- addListener
  
  public void addListener(ActionListener<T> listener)
  
  Description copied from interface: ListenableActionFuture
  
  Add an action listener to be invoked when a response has received.
  
  Specified by:
  
  addListener in interface ListenableActionFuture<T>
- done
  
  protected void done()
  
  Overrides:
  
  done in class BaseFuture<T>
- convert
  
  protected T convert(T listenerResponse)
  
  Specified by:
  
  convert in class AdapterActionFuture<T,T>

Class PlainListenableActionFuture<T>