org.apache.hc.client5.http.impl.async

Class CloseableHttpAsyncClient

java.lang.Object

org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient

All Implemented Interfaces:

Closeable, AutoCloseable, HttpAsyncClient

Direct Known Subclasses:

MinimalHttp2AsyncClient, MinimalHttpAsyncClient

@Contract(threading=SAFE)
public abstract class CloseableHttpAsyncClient
extends Object
implements HttpAsyncClient, Closeable

Base implementation of HttpAsyncClient that also implements Closeable.

Since:

4.0

Constructor Summary

Constructors

Constructor and Description
CloseableHttpAsyncClient()

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime)
<T> Future<T>	execute(org.apache.hc.core5.http.nio.AsyncRequestProducer requestProducer, org.apache.hc.core5.http.nio.AsyncResponseConsumer<T> responseConsumer, org.apache.hc.core5.concurrent.FutureCallback<T> callback)
Future<SimpleHttpResponse>	execute(SimpleHttpRequest request, org.apache.hc.core5.concurrent.FutureCallback<SimpleHttpResponse> callback)
Future<SimpleHttpResponse>	execute(SimpleHttpRequest request, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<SimpleHttpResponse> callback)
abstract List<org.apache.hc.core5.reactor.ExceptionEvent>	getExceptionLog()
abstract org.apache.hc.core5.reactor.IOReactorStatus	getStatus()
abstract void	initiateShutdown()
void	register(String uriPattern, org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier)
abstract void	shutdown(org.apache.hc.core5.io.ShutdownType shutdownType)
abstract void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hc.client5.http.async.HttpAsyncClient

execute, register

Methods inherited from interface java.io.Closeable

close

Constructor Detail

CloseableHttpAsyncClient

public CloseableHttpAsyncClient()

Method Detail

start

public abstract void start()

getStatus

public abstract org.apache.hc.core5.reactor.IOReactorStatus getStatus()

getExceptionLog

public abstract List<org.apache.hc.core5.reactor.ExceptionEvent> getExceptionLog()

awaitShutdown

public abstract void awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime)
                            throws InterruptedException

Throws:

InterruptedException

initiateShutdown

public abstract void initiateShutdown()

shutdown

public abstract void shutdown(org.apache.hc.core5.io.ShutdownType shutdownType)

execute

public final <T> Future<T> execute(org.apache.hc.core5.http.nio.AsyncRequestProducer requestProducer,
                    org.apache.hc.core5.http.nio.AsyncResponseConsumer<T> responseConsumer,
                    org.apache.hc.core5.concurrent.FutureCallback<T> callback)

register

public final void register(String uriPattern,
            org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier)

execute

public final Future<SimpleHttpResponse> execute(SimpleHttpRequest request,
                                 org.apache.hc.core5.http.protocol.HttpContext context,
                                 org.apache.hc.core5.concurrent.FutureCallback<SimpleHttpResponse> callback)

execute

public final Future<SimpleHttpResponse> execute(SimpleHttpRequest request,
                                 org.apache.hc.core5.concurrent.FutureCallback<SimpleHttpResponse> callback)