org.apache.hc.client5.http.impl.async

Class InternalHttp2AsyncClient

java.lang.Object

org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient

org.apache.hc.client5.http.impl.async.InternalHttp2AsyncClient

All Implemented Interfaces:

Closeable, AutoCloseable, HttpAsyncClient

@Contract(threading=SAFE_CONDITIONAL)
@Internal
public final class InternalHttp2AsyncClient
extends CloseableHttpAsyncClient

Internal implementation of HTTP/2 only CloseableHttpAsyncClient.

Concurrent message exchanges with the same connection route executed by this client will get automatically multiplexed over a single physical HTTP/2 connection.

Since:

5.0

Method Summary

Methods

Modifier and Type	Method and Description
void	awaitShutdown(TimeValue waitTime)
void	close()
<T> Future<T>	execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context, FutureCallback<T> callback) Initiates asynchronous HTTP request execution using the given context.
List<ExceptionEvent>	getExceptionLog()
IOReactorStatus	getStatus()
void	initiateShutdown()
void	register(String hostname, String uriPattern, Supplier<AsyncPushConsumer> supplier)
void	shutdown(CloseMode closeMode)
void	start()

Methods inherited from class org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient

execute, execute, execute, execute, register

Methods inherited from class java.lang.Object

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

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

execute

public <T> Future<T> execute(AsyncRequestProducer requestProducer,
                    AsyncResponseConsumer<T> responseConsumer,
                    HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
                    HttpContext context,
                    FutureCallback<T> callback)

Description copied from interface: HttpAsyncClient

Initiates asynchronous HTTP request execution using the given context.

The request producer passed to this method will be used to generate a request message and stream out its content without buffering it in memory. The response consumer passed to this method will be used to process a response message without buffering its content in memory.

Please note it may be unsafe to interact with the context instance while the request is still being executed.

Type Parameters:

T - the result type of request execution.

Parameters:

requestProducer - request producer callback.

responseConsumer - response consumer callback.

pushHandlerFactory - the push handler factory. Optional and may be null.

context - HTTP context. Optional and may be null.

callback - future callback. Optional and may be null.

Returns:

future representing pending completion of the operation.

start

public final void start()

Specified by:

start in class CloseableHttpAsyncClient

register

public void register(String hostname,
            String uriPattern,
            Supplier<AsyncPushConsumer> supplier)

Specified by:

register in class CloseableHttpAsyncClient

getStatus

public final IOReactorStatus getStatus()

Specified by:

getStatus in class CloseableHttpAsyncClient

getExceptionLog

public final List<ExceptionEvent> getExceptionLog()

Specified by:

getExceptionLog in class CloseableHttpAsyncClient

awaitShutdown

public final void awaitShutdown(TimeValue waitTime)
                         throws InterruptedException

Specified by:

awaitShutdown in class CloseableHttpAsyncClient

Throws:

InterruptedException

initiateShutdown

public final void initiateShutdown()

Specified by:

initiateShutdown in class CloseableHttpAsyncClient

shutdown

public final void shutdown(CloseMode closeMode)

Specified by:

shutdown in class CloseableHttpAsyncClient