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

Class InternalH2AsyncClient

java.lang.Object

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

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

All Implemented Interfaces:

HttpAsyncClient

public final class InternalH2AsyncClient
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

Modifier and Type	Method and Description
void	awaitShutdown(TimeValue waitTime)
void	close()
void	close(CloseMode closeMode)
protected <T> java.util.concurrent.Future<T>	doExecute(HttpHost httpHost, AsyncRequestProducer requestProducer, <any> responseConsumer, <any> pushHandlerFactory, HttpContext context, <any> callback)
IOReactorStatus	getStatus()
void	initiateShutdown()
void	register(java.lang.String hostname, java.lang.String uriPattern, <any> supplier)
void	start()

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

execute, execute, 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

doExecute

protected <T> java.util.concurrent.Future<T> doExecute(HttpHost httpHost,
                                                       AsyncRequestProducer requestProducer,
                                                       <any> responseConsumer,
                                                       <any> pushHandlerFactory,
                                                       HttpContext context,
                                                       <any> callback)

Specified by:

doExecute in class CloseableHttpAsyncClient

start

public final void start()

Specified by:

start in class CloseableHttpAsyncClient

register

public void register(java.lang.String hostname,
                     java.lang.String uriPattern,
                     <any> supplier)

Specified by:

register in class CloseableHttpAsyncClient

getStatus

public final IOReactorStatus getStatus()

Specified by:

getStatus in class CloseableHttpAsyncClient

awaitShutdown

public final void awaitShutdown(TimeValue waitTime)
                         throws java.lang.InterruptedException

Specified by:

awaitShutdown in class CloseableHttpAsyncClient

Throws:

java.lang.InterruptedException

initiateShutdown

public final void initiateShutdown()

Specified by:

initiateShutdown in class CloseableHttpAsyncClient

close

public final void close(CloseMode closeMode)

close

public void close()