Package 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.AbstractHttpAsyncClientBase

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

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, HttpAsyncClient, org.apache.hc.core5.io.ModalCloseable

@Contract(threading=SAFE_CONDITIONAL)
@Internal
public final class InternalH2AsyncClient
extends InternalAbstractHttpAsyncClient

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

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hc.client5.http.impl.async.InternalAbstractHttpAsyncClient

InternalAbstractHttpAsyncClient.ScheduledRequestExecution

Nested classes/interfaces inherited from class org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase

AbstractHttpAsyncClientBase.Status

Field Summary

Fields

Modifier and Type	Field	Description
private InternalH2ConnPool	connPool
private static org.slf4j.Logger	LOG
private HttpRoutePlanner	routePlanner

Constructor Summary

Constructors

Constructor

Description

InternalH2AsyncClient(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncExecChainElement execChain, AsyncPushConsumerRegistry pushConsumerRegistry, java.util.concurrent.ThreadFactory threadFactory, InternalH2ConnPool connPool, HttpRoutePlanner routePlanner, org.apache.hc.core5.http.config.Lookup<CookieSpecFactory> cookieSpecRegistry, org.apache.hc.core5.http.config.Lookup<AuthSchemeFactory> authSchemeRegistry, CookieStore cookieStore, CredentialsProvider credentialsProvider, RequestConfig defaultConfig, java.util.List<java.io.Closeable> closeables)

Method Summary

Modifier and Type	Method	Description
(package private) AsyncExecRuntime	createAsyncExecRuntime(org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory)
(package private) HttpRoute	determineRoute(org.apache.hc.core5.http.HttpHost httpHost, HttpClientContext clientContext)

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

doExecute, executeImmediate, executeScheduled, internalClose

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

awaitShutdown, close, close, getConnectionInitiator, getStatus, initiateShutdown, isRunning, register, 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

Field Detail

LOG

private static final org.slf4j.Logger LOG

routePlanner

private final HttpRoutePlanner routePlanner

connPool

private final InternalH2ConnPool connPool

Constructor Detail

InternalH2AsyncClient

InternalH2AsyncClient(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor,
                      AsyncExecChainElement execChain,
                      AsyncPushConsumerRegistry pushConsumerRegistry,
                      java.util.concurrent.ThreadFactory threadFactory,
                      InternalH2ConnPool connPool,
                      HttpRoutePlanner routePlanner,
                      org.apache.hc.core5.http.config.Lookup<CookieSpecFactory> cookieSpecRegistry,
                      org.apache.hc.core5.http.config.Lookup<AuthSchemeFactory> authSchemeRegistry,
                      CookieStore cookieStore,
                      CredentialsProvider credentialsProvider,
                      RequestConfig defaultConfig,
                      java.util.List<java.io.Closeable> closeables)

Method Detail

createAsyncExecRuntime

AsyncExecRuntime createAsyncExecRuntime(org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory)

Specified by:

createAsyncExecRuntime in class InternalAbstractHttpAsyncClient

determineRoute

HttpRoute determineRoute(org.apache.hc.core5.http.HttpHost httpHost,
                         HttpClientContext clientContext)
                  throws org.apache.hc.core5.http.HttpException

Specified by:

determineRoute in class InternalAbstractHttpAsyncClient

Throws:

org.apache.hc.core5.http.HttpException