Top Inners Fields Constructors Methods
org.apache.hc.client5.http.impl.async

pack-priv abstract Class InternalAbstractHttpAsyncClient

extends AbstractHttpAsyncClientBase
Class Inheritance
Known Direct Subclasses
org.apache.hc.client5.http.impl.async.InternalH2AsyncClient, org.apache.hc.client5.http.impl.async.InternalHttpAsyncClient
Imports
java.io.Closeable, .IOException, java.util.List, .Set, java.util.concurrent.CancellationException, .ConcurrentLinkedQueue, .Executors, .Future, .ScheduledExecutorService, .ThreadFactory, java.util.concurrent.atomic.AtomicBoolean, .AtomicInteger, org.apache.hc.client5.http.HttpRoute, org.apache.hc.client5.http.async.AsyncExecCallback, .AsyncExecChain, .AsyncExecRuntime, org.apache.hc.client5.http.auth.AuthSchemeFactory, .CredentialsProvider, org.apache.hc.client5.http.config.Configurable, .RequestConfig, org.apache.hc.client5.http.cookie.CookieSpecFactory, .CookieStore, org.apache.hc.client5.http.impl.ExecSupport, org.apache.hc.client5.http.protocol.HttpClientContext, org.apache.hc.client5.http.routing.RoutingSupport, org.apache.hc.core5.concurrent.Cancellable, .ComplexFuture, .DefaultThreadFactory, .FutureCallback, org.apache.hc.core5.http.EntityDetails, .HttpException, .HttpHost, .HttpRequest, .HttpResponse, .HttpStatus, org.apache.hc.core5.http.config.Lookup, org.apache.hc.core5.http.nio.AsyncDataConsumer, .AsyncEntityProducer, .AsyncPushConsumer, .AsyncRequestProducer, .AsyncResponseConsumer, .DataStreamChannel, .HandlerFactory, org.apache.hc.core5.http.protocol.HttpContext, org.apache.hc.core5.http.support.BasicRequestBuilder, org.apache.hc.core5.io.CloseMode, .ModalCloseable, org.apache.hc.core5.reactor.DefaultConnectingIOReactor, org.apache.hc.core5.util.TimeValue, org.slf4j.Logger, .LoggerFactory

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
InternalAbstractHttpAsyncClient.ScheduledRequestExecution

Field Summary

Modifier and TypeField and Description
private final Lookup<AuthSchemeFactory>
authSchemeRegistry

private final ConcurrentLinkedQueue<Closeable>
closeables

private final Lookup<CookieSpecFactory>
cookieSpecRegistry

private final CookieStore
cookieStore

private final CredentialsProvider
credentialsProvider

private final RequestConfig
defaultConfig

private final AsyncExecChainElement
execChain

private static final Logger
LOG

Hides org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase.LOG.

private final ScheduledExecutorService
scheduledExecutorService

private final AsyncExecChain.Scheduler
scheduler

private static final ThreadFactory
SCHEDULER_THREAD_FACTORY

Constructor Summary

AccessConstructor and Description
pack-priv
InternalAbstractHttpAsyncClient(final DefaultConnectingIOReactor ioReactor, final AsyncPushConsumerRegistry pushConsumerRegistry, final ThreadFactory threadFactory, final AsyncExecChainElement execChain, final Lookup<CookieSpecFactory> cookieSpecRegistry, final Lookup<AuthSchemeFactory> authSchemeRegistry, final CookieStore cookieStore, final CredentialsProvider credentialsProvider, final RequestConfig defaultConfig, final List<Closeable> closeables)

Method Summary

Modifier and TypeMethod and Description
pack-priv abstract AsyncExecRuntime
createAsyncExecRuntime(HandlerFactory<AsyncPushConsumer> pushHandlerFactory)

pack-priv abstract HttpRoute
determineRoute(HttpHost httpHost, HttpClientContext clientContext)

protected <T> Future<T>
doExecute(final HttpHost httpHost, final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpContext context, final FutureCallback<T> callback)

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.doExecute.

pack-priv void
executeImmediate(final HttpRequest request, final AsyncEntityProducer entityProducer, final AsyncExecChain.Scope scope, final AsyncExecChain chain, final AsyncExecCallback asyncExecCallback)

pack-priv void
executeScheduled(final HttpRequest request, final AsyncEntityProducer entityProducer, final AsyncExecChain.Scope scope, final AsyncExecChain chain, final AsyncExecCallback asyncExecCallback, final TimeValue delay)

pack-priv void
internalClose(final CloseMode closeMode)

Overrides org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase.internalClose.

private void
setupContext(final HttpClientContext context)

Inherited from org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase:
awaitShutdowncloseclosegetConnectionInitiatorgetStatusinitiateShutdownisRunningregisterstart

Field Detail

authSchemeRegistryback to summary
private final Lookup<AuthSchemeFactory> authSchemeRegistry
closeablesback to summary
private final ConcurrentLinkedQueue<Closeable> closeables
cookieSpecRegistryback to summary
private final Lookup<CookieSpecFactory> cookieSpecRegistry
cookieStoreback to summary
private final CookieStore cookieStore
credentialsProviderback to summary
private final CredentialsProvider credentialsProvider
defaultConfigback to summary
private final RequestConfig defaultConfig
execChainback to summary
private final AsyncExecChainElement execChain
LOGback to summary
private static final Logger LOG

Hides org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase.LOG.

scheduledExecutorServiceback to summary
private final ScheduledExecutorService scheduledExecutorService
schedulerback to summary
private final AsyncExecChain.Scheduler scheduler
SCHEDULER_THREAD_FACTORYback to summary
private static final ThreadFactory SCHEDULER_THREAD_FACTORY

Constructor Detail

InternalAbstractHttpAsyncClientback to summary
pack-priv InternalAbstractHttpAsyncClient(final DefaultConnectingIOReactor ioReactor, final AsyncPushConsumerRegistry pushConsumerRegistry, final ThreadFactory threadFactory, final AsyncExecChainElement execChain, final Lookup<CookieSpecFactory> cookieSpecRegistry, final Lookup<AuthSchemeFactory> authSchemeRegistry, final CookieStore cookieStore, final CredentialsProvider credentialsProvider, final RequestConfig defaultConfig, final List<Closeable> closeables)

Method Detail

createAsyncExecRuntimeback to summary
pack-priv abstract AsyncExecRuntime createAsyncExecRuntime(HandlerFactory<AsyncPushConsumer> pushHandlerFactory)
determineRouteback to summary
pack-priv abstract HttpRoute determineRoute(HttpHost httpHost, HttpClientContext clientContext) throws HttpException
doExecuteback to summary
protected <T> Future<T> doExecute(final HttpHost httpHost, final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpContext context, final FutureCallback<T> callback)

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.doExecute.

Annotations
@Override
executeImmediateback to summary
pack-priv void executeImmediate(final HttpRequest request, final AsyncEntityProducer entityProducer, final AsyncExecChain.Scope scope, final AsyncExecChain chain, final AsyncExecCallback asyncExecCallback) throws HttpException, IOException
executeScheduledback to summary
pack-priv void executeScheduled(final HttpRequest request, final AsyncEntityProducer entityProducer, final AsyncExecChain.Scope scope, final AsyncExecChain chain, final AsyncExecCallback asyncExecCallback, final TimeValue delay)
internalCloseback to summary
pack-priv void internalClose(final CloseMode closeMode)

Overrides org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase.internalClose.

Annotations
@Override
setupContextback to summary
private void setupContext(final HttpClientContext context)
org.apache.hc.client5.http.impl.async back to summary

pack-priv Class InternalAbstractHttpAsyncClient.ScheduledRequestExecution

extends Object
implements Runnable, Cancellable
Class Inheritance
  • java.lang.Object
  • org.apache.hc.client5.http.impl.async.InternalAbstractHttpAsyncClient.ScheduledRequestExecution
All Implemented Interfaces
org.apache.hc.core5.concurrent.Cancellable, java.lang.Runnable

Field Summary

Modifier and TypeField and Description
pack-priv final AsyncExecCallback
asyncExecCallback

pack-priv final AsyncExecChain
chain

pack-priv final TimeValue
delay

pack-priv final AsyncEntityProducer
entityProducer

pack-priv final HttpRequest
request

pack-priv final AsyncExecChain.Scope
scope

Constructor Summary

AccessConstructor and Description
pack-priv
ScheduledRequestExecution(final HttpRequest request, final AsyncEntityProducer entityProducer, final AsyncExecChain.Scope scope, final AsyncExecChain chain, final AsyncExecCallback asyncExecCallback, final TimeValue delay)

Method Summary

Modifier and TypeMethod and Description
public boolean
cancel()

Implements org.apache.hc.core5.concurrent.Cancellable.cancel.

Cancels the ongoing operation or process.
public void
run()

Implements java.lang.Runnable.run.

Runs this operation.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

asyncExecCallbackback to summary
pack-priv final AsyncExecCallback asyncExecCallback
chainback to summary
pack-priv final AsyncExecChain chain
delayback to summary
pack-priv final TimeValue delay
entityProducerback to summary
pack-priv final AsyncEntityProducer entityProducer
requestback to summary
pack-priv final HttpRequest request
scopeback to summary
pack-priv final AsyncExecChain.Scope scope

Constructor Detail

ScheduledRequestExecutionback to summary
pack-priv ScheduledRequestExecution(final HttpRequest request, final AsyncEntityProducer entityProducer, final AsyncExecChain.Scope scope, final AsyncExecChain chain, final AsyncExecCallback asyncExecCallback, final TimeValue delay)

Method Detail

cancelback to summary
public boolean cancel()

Implements org.apache.hc.core5.concurrent.Cancellable.cancel.

Doc from org.apache.hc.core5.concurrent.Cancellable.cancel.

Cancels the ongoing operation or process.

Returns:boolean

true if the operation or process has been cancelled as a result of this method call or false if it has already been cancelled or not started.

Annotations
@Override
runback to summary
public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations
@Override