Package co.elastic.clients.transport.rest5_client.low_level

Class HttpAsyncResponseConsumerFactory.BasicAsyncResponseConsumerFactory

java.lang.Object

co.elastic.clients.transport.rest5_client.low_level.HttpAsyncResponseConsumerFactory.BasicAsyncResponseConsumerFactory

All Implemented Interfaces:

HttpAsyncResponseConsumerFactory

Enclosing interface:

HttpAsyncResponseConsumerFactory

public static class HttpAsyncResponseConsumerFactory.BasicAsyncResponseConsumerFactory
extends Object
implements HttpAsyncResponseConsumerFactory

Default factory used to create instances of AsyncResponseConsumer. Creates one instance of BasicAsyncResponseConsumer for each request attempt, with a configurable buffer limit which defaults to 100MB.

Nested Class Summary

Nested classes/interfaces inherited from interface co.elastic.clients.transport.rest5_client.low_level.HttpAsyncResponseConsumerFactory

HttpAsyncResponseConsumerFactory.BasicAsyncResponseConsumerFactory

Field Summary

Fields inherited from interface co.elastic.clients.transport.rest5_client.low_level.HttpAsyncResponseConsumerFactory

DEFAULT

Constructor Summary

Constructors

Constructor	Description
BasicAsyncResponseConsumerFactory(int bufferLimit)

Method Summary

Modifier and Type	Method	Description
org.apache.hc.core5.http.nio.AsyncResponseConsumer<org.apache.hc.core5.http.ClassicHttpResponse>	createHttpAsyncResponseConsumer()	Creates the AbstractAsyncResponseConsumer, called once per request attempt.

Methods inherited from class java.lang.Object

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

Constructor Details

BasicAsyncResponseConsumerFactory

public BasicAsyncResponseConsumerFactory(int bufferLimit)

Method Details

createHttpAsyncResponseConsumer

public org.apache.hc.core5.http.nio.AsyncResponseConsumer<org.apache.hc.core5.http.ClassicHttpResponse> createHttpAsyncResponseConsumer()

Description copied from interface: HttpAsyncResponseConsumerFactory

Creates the AbstractAsyncResponseConsumer, called once per request attempt.

Specified by:

createHttpAsyncResponseConsumer in interface HttpAsyncResponseConsumerFactory