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:
Closeable
,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
FieldsModifier and TypeFieldDescriptionprivate final InternalH2ConnPool
private static final org.slf4j.Logger
private final HttpRoutePlanner
-
Constructor Summary
ConstructorsConstructorDescriptionInternalH2AsyncClient
(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncExecChainElement execChain, AsyncPushConsumerRegistry pushConsumerRegistry, 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, List<Closeable> closeables) -
Method Summary
Modifier and TypeMethodDescription(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
-
Field Details
-
LOG
private static final org.slf4j.Logger LOG -
routePlanner
-
connPool
-
-
Constructor Details
-
InternalH2AsyncClient
InternalH2AsyncClient(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncExecChainElement execChain, AsyncPushConsumerRegistry pushConsumerRegistry, 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, List<Closeable> closeables)
-
-
Method Details
-
createAsyncExecRuntime
AsyncExecRuntime createAsyncExecRuntime(org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory) - Specified by:
createAsyncExecRuntime
in classInternalAbstractHttpAsyncClient
-
determineRoute
HttpRoute determineRoute(org.apache.hc.core5.http.HttpHost httpHost, HttpClientContext clientContext) throws org.apache.hc.core5.http.HttpException - Specified by:
determineRoute
in classInternalAbstractHttpAsyncClient
- Throws:
org.apache.hc.core5.http.HttpException
-