Package org.elasticsearch.action.support

Class PlainActionFuture<T>

java.lang.Object

org.elasticsearch.common.util.concurrent.BaseFuture<T>

org.elasticsearch.action.support.AdapterActionFuture<T,T>

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

All Implemented Interfaces:

Future<T>, ActionFuture<T>, ActionListener<T>

public class PlainActionFuture<T>
extends AdapterActionFuture<T,T>

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.action.ActionListener

ActionListener.Delegating<Response,DelegateResponse>, ActionListener.DelegatingActionListener<T>, ActionListener.DelegatingFailureActionListener<T,R>, ActionListener.MappedActionListener<Response,MappedResponse>, ActionListener.RunAfterActionListener<T>, ActionListener.RunBeforeActionListener<T>

Constructor Summary

Constructors

Constructor	Description
PlainActionFuture()

Method Summary

Modifier and Type	Method	Description
protected T	convert(T listenerResponse)
static <T, E extends Exception> T	get(CheckedConsumer<PlainActionFuture<T>,E> e)
static <T, E extends Exception> T	get(CheckedConsumer<PlainActionFuture<T>,E> e, long timeout, TimeUnit unit)
static <T> PlainActionFuture<T>	newFuture()

Methods inherited from class org.elasticsearch.action.support.AdapterActionFuture

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

Methods inherited from class org.elasticsearch.common.util.concurrent.BaseFuture

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.action.ActionListener

delegateFailure, delegateResponse, map

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Constructor Details

PlainActionFuture

public PlainActionFuture()

Method Details

newFuture

public static <T> PlainActionFuture<T> newFuture()

get

public static <T,
E extends Exception> T get(CheckedConsumer<PlainActionFuture<T>,E> e)
                                     throws E

Throws:

E extends Exception

get

public static <T,
E extends Exception> T get(CheckedConsumer<PlainActionFuture<T>,E> e,
 long timeout,
 TimeUnit unit)
                                     throws E

Throws:

E extends Exception

convert

protected T convert(T listenerResponse)

Specified by:

convert in class AdapterActionFuture<T,T>