Class GroupedActionListener<T>

java.lang.Object
org.elasticsearch.action.ActionListener.Delegating<T,Collection<T>>
org.elasticsearch.action.support.GroupedActionListener<T>
All Implemented Interfaces:
ActionListener<T>

public final class GroupedActionListener<T> extends ActionListener.Delegating<T,Collection<T>>
An action listener that delegates its results to another listener once it has received N results (either successes or failures). This allows synchronous tasks to be forked off in a loop with the same listener and respond to a higher level listener once all tasks responded.
  • Constructor Details

    • GroupedActionListener

      public GroupedActionListener(ActionListener<Collection<T>> delegate, int groupSize)
      Creates a new listener
      Parameters:
      delegate - the delegate listener
      groupSize - the group size
  • Method Details