java.lang.Object

org.elasticsearch.action.LatchedActionListener<T>

public class LatchedActionListener<T>
extends java.lang.Object
implements ActionListener<T>

An action listener that allows passing in a CountDownLatch that will be counted down after onResponse or onFailure is called

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

LatchedActionListener(ActionListener<T> delegate, java.util.concurrent.CountDownLatch latch)

Method Summary

Modifier and Type	Method	Description
`void`	`onFailure(java.lang.Exception e)`	A failure caused by an exception at some phase of the task.
`void`	`onResponse(T t)`	Handle action response.

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

delegateFailure, delegateResponse, map

Constructor Details
- LatchedActionListener
  
  public LatchedActionListener(ActionListener<T> delegate, java.util.concurrent.CountDownLatch latch)
Method Details
- onResponse
  
  public void onResponse(T t)
  
  Description copied from interface: ActionListener
  
  Handle action response. This response may constitute a failure or a success but it is up to the listener to make that decision.
  
  Specified by:
  
  onResponse in interface ActionListener<T>
- onFailure
  
  public void onFailure(java.lang.Exception e)
  
  Description copied from interface: ActionListener
  
  A failure caused by an exception at some phase of the task.
  
  Specified by:
  
  onFailure in interface ActionListener<T>

Class LatchedActionListener<T>