Package org.elasticsearch.http
Class HttpPipeliningAggregator<Listener>
org.elasticsearch.http.HttpPipeliningAggregator<Listener>
public class HttpPipeliningAggregator<Listener>
extends
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionread(HttpRequest request)
<org.elasticsearch.core.Tuple<HttpPipelinedResponse,Listener>>
<org.elasticsearch.core.Tuple<HttpPipelinedResponse,Listener>>
write(HttpPipelinedResponse response, Listener listener)
Methods inherited from class java.lang.
, , , , , , , , , ,
-
Constructor Details
-
HttpPipeliningAggregator
public HttpPipeliningAggregator(int maxEventsHeld)
-
-
Method Details
-
read
-
write
public <org.elasticsearch.core.Tuple<HttpPipelinedResponse,Listener>> write(HttpPipelinedResponse response, Listener listener) -
removeAllInflightResponses
-