java.lang.Object

org.elasticsearch.http.HttpPipeliningAggregator<Response,Listener>

public class HttpPipeliningAggregator<Response extends HttpPipelinedMessage,Listener>
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
`<Request> HttpPipelinedRequest<Request>`	`read(Request request)`
`java.util.List<Tuple<Response,Listener>>`	`removeAllInflightResponses()`
`java.util.List<Tuple<Response,Listener>>`	`write(Response response, Listener listener)`

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

Constructor Details
- HttpPipeliningAggregator
  
  public HttpPipeliningAggregator(int maxEventsHeld)
Method Details
- read
  
  public <Request> HttpPipelinedRequest<Request> read(Request request)
- write
  
  public java.util.List<Tuple<Response,Listener>> write(Response response, Listener listener)
- removeAllInflightResponses
  
  public java.util.List<Tuple<Response,Listener>> removeAllInflightResponses()

Class HttpPipeliningAggregator<Response extends HttpPipelinedMessage,​Listener>