Package org.elasticsearch.http

Class HttpPipeliningAggregator<Listener>

java.lang.Object

org.elasticsearch.http.HttpPipeliningAggregator<Listener>

public class HttpPipeliningAggregator<Listener>
extends Object

Constructor Summary

Constructors

Constructor	Description
HttpPipeliningAggregator(int maxEventsHeld)

Method Summary

Modifier and Type	Method	Description
HttpPipelinedRequest	read(HttpRequest request)
List<Tuple<HttpPipelinedResponse,Listener>>	removeAllInflightResponses()
List<Tuple<HttpPipelinedResponse,Listener>>	write(HttpPipelinedResponse response, Listener listener)

Methods inherited from class java.lang.Object

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

Constructor Details

HttpPipeliningAggregator

public HttpPipeliningAggregator(int maxEventsHeld)

Method Details

read

public HttpPipelinedRequest read(HttpRequest request)

write

public List<Tuple<HttpPipelinedResponse,Listener>> write(HttpPipelinedResponse response,
 Listener listener)

removeAllInflightResponses

public List<Tuple<HttpPipelinedResponse,Listener>> removeAllInflightResponses()