@Contract(threading=SAFE_CONDITIONAL) @Internal public final class InternalH2AsyncClient extends CloseableHttpAsyncClient
CloseableHttpAsyncClient.
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(org.apache.hc.core5.util.TimeValue waitTime) |
void |
close() |
void |
close(org.apache.hc.core5.io.CloseMode closeMode) |
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) |
org.apache.hc.core5.reactor.IOReactorStatus |
getStatus() |
void |
initiateShutdown() |
void |
register(String hostname,
String uriPattern,
org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier) |
void |
start() |
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)
doExecute in class CloseableHttpAsyncClientpublic final void start()
start in class CloseableHttpAsyncClientpublic void register(String hostname, String uriPattern, org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier)
register in class CloseableHttpAsyncClientpublic final org.apache.hc.core5.reactor.IOReactorStatus getStatus()
getStatus in class CloseableHttpAsyncClientpublic final void awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime)
throws InterruptedException
awaitShutdown in class CloseableHttpAsyncClientInterruptedExceptionpublic final void initiateShutdown()
initiateShutdown in class CloseableHttpAsyncClientpublic final void close(org.apache.hc.core5.io.CloseMode closeMode)
public void close()
Copyright © 1999–2021 The Apache Software Foundation. All rights reserved.