Class InternalAbstractHttpAsyncClient
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
- All Implemented Interfaces:
Closeable
,AutoCloseable
,HttpAsyncClient
,org.apache.hc.core5.io.ModalCloseable
- Direct Known Subclasses:
InternalH2AsyncClient
,InternalHttpAsyncClient
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) class
Nested classes/interfaces inherited from class org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase
AbstractHttpAsyncClientBase.Status
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final org.apache.hc.core5.http.config.Lookup
<AuthSchemeFactory> private final ConcurrentLinkedQueue
<Closeable> private final org.apache.hc.core5.http.config.Lookup
<CookieSpecFactory> private final CookieStore
private final CredentialsProvider
private final RequestConfig
private final AsyncExecChainElement
private static final org.slf4j.Logger
private final ScheduledExecutorService
private final AsyncExecChain.Scheduler
private static final ThreadFactory
-
Constructor Summary
ConstructorsConstructorDescriptionInternalAbstractHttpAsyncClient
(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncPushConsumerRegistry pushConsumerRegistry, ThreadFactory threadFactory, AsyncExecChainElement execChain, 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) abstract AsyncExecRuntime
createAsyncExecRuntime
(org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory) (package private) abstract HttpRoute
determineRoute
(org.apache.hc.core5.http.HttpHost httpHost, HttpClientContext clientContext) protected <T> Future
<T> doExecute
(org.apache.hc.core5.http.HttpHost httpHost, org.apache.hc.core5.http.nio.AsyncRequestProducer requestProducer, org.apache.hc.core5.http.nio.AsyncResponseConsumer<T> responseConsumer, org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<T> callback) (package private) void
executeImmediate
(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer, AsyncExecChain.Scope scope, AsyncExecChain chain, AsyncExecCallback asyncExecCallback) (package private) void
executeScheduled
(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer, AsyncExecChain.Scope scope, AsyncExecChain chain, AsyncExecCallback asyncExecCallback, org.apache.hc.core5.util.TimeValue delay) (package private) void
internalClose
(org.apache.hc.core5.io.CloseMode closeMode) private void
setupContext
(HttpClientContext context) Methods inherited from class org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase
awaitShutdown, close, close, getConnectionInitiator, getStatus, initiateShutdown, isRunning, register, start
-
Field Details
-
SCHEDULER_THREAD_FACTORY
-
LOG
private static final org.slf4j.Logger LOG -
execChain
-
cookieSpecRegistry
-
authSchemeRegistry
-
cookieStore
-
credentialsProvider
-
defaultConfig
-
closeables
-
scheduledExecutorService
-
scheduler
-
-
Constructor Details
-
InternalAbstractHttpAsyncClient
InternalAbstractHttpAsyncClient(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncPushConsumerRegistry pushConsumerRegistry, ThreadFactory threadFactory, AsyncExecChainElement execChain, 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
-
internalClose
void internalClose(org.apache.hc.core5.io.CloseMode closeMode) - Overrides:
internalClose
in classAbstractHttpAsyncClientBase
-
setupContext
-
createAsyncExecRuntime
abstract AsyncExecRuntime createAsyncExecRuntime(org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory) -
determineRoute
abstract HttpRoute determineRoute(org.apache.hc.core5.http.HttpHost httpHost, HttpClientContext clientContext) throws org.apache.hc.core5.http.HttpException - Throws:
org.apache.hc.core5.http.HttpException
-
doExecute
protected <T> Future<T> doExecute(org.apache.hc.core5.http.HttpHost httpHost, org.apache.hc.core5.http.nio.AsyncRequestProducer requestProducer, org.apache.hc.core5.http.nio.AsyncResponseConsumer<T> responseConsumer, org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<T> callback) - Specified by:
doExecute
in classCloseableHttpAsyncClient
-
executeImmediate
void executeImmediate(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer, AsyncExecChain.Scope scope, AsyncExecChain chain, AsyncExecCallback asyncExecCallback) throws org.apache.hc.core5.http.HttpException, IOException - Throws:
org.apache.hc.core5.http.HttpException
IOException
-
executeScheduled
void executeScheduled(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer, AsyncExecChain.Scope scope, AsyncExecChain chain, AsyncExecCallback asyncExecCallback, org.apache.hc.core5.util.TimeValue delay)
-