public final class MinimalH2AsyncClient extends CloseableHttpAsyncClient
CloseableHttpAsyncClient. This client
is optimized for HTTP/2 multiplexing message transport and does not support advanced
HTTP protocol functionality such as request execution via a proxy, state management,
authentication and request redirects.
Concurrent message exchanges with the same connection route executed by this client will get automatically multiplexed over a single physical HTTP/2 connection.
| 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) |
Cancellable |
execute(AsyncClientExchangeHandler exchangeHandler) |
Cancellable |
execute(AsyncClientExchangeHandler exchangeHandler,
<any> pushHandlerFactory,
HttpContext context) |
IOReactorStatus |
getStatus() |
void |
initiateShutdown() |
void |
register(java.lang.String hostname,
java.lang.String uriPattern,
<any> supplier) |
void |
start() |
public Cancellable execute(AsyncClientExchangeHandler exchangeHandler,
<any> pushHandlerFactory,
HttpContext context)
protected <T> java.util.concurrent.Future<T> doExecute(HttpHost httpHost,
AsyncRequestProducer requestProducer,
<any> responseConsumer,
<any> pushHandlerFactory,
HttpContext context,
<any> callback)
doExecute in class CloseableHttpAsyncClientpublic final Cancellable execute(AsyncClientExchangeHandler exchangeHandler)
public final void start()
start in class CloseableHttpAsyncClientpublic void register(java.lang.String hostname,
java.lang.String uriPattern,
<any> supplier)
register in class CloseableHttpAsyncClientpublic final IOReactorStatus getStatus()
getStatus in class CloseableHttpAsyncClientpublic final void awaitShutdown(TimeValue waitTime)
throws java.lang.InterruptedException
awaitShutdown in class CloseableHttpAsyncClientjava.lang.InterruptedExceptionpublic final void initiateShutdown()
initiateShutdown in class CloseableHttpAsyncClientpublic final void close(CloseMode closeMode)
public void close()