HttpAsyncClient that also implements ModalCloseable.
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public abstract void | |
| protected abstract <T> Future | doExecute(final HttpHost target, final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpContext context, final FutureCallback<T> callback)
|
| public final <T> Future | execute(final HttpHost target, final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpContext context, final FutureCallback<T> callback)
|
| public final <T> Future | execute(final AsyncRequestProducer
request producer callback. requestProducer, final AsyncResponseConsumer<T> response consumer callback. responseConsumer, final HandlerFactory<AsyncPushConsumer> the push handler factory. Optional and may be pushHandlerFactory, final HttpContext null.HTTP context. Optional and may be context, final FutureCallback<T> null.future callback. Optional and may be callback)null.Implements org. |
| public final <T> Future | execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final HttpContext context, final FutureCallback<T> callback)
|
| public final <T> Future | execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final FutureCallback<T> callback)
|
| public final Future | execute(final SimpleHttpRequest request, final HttpContext context, final FutureCallback<SimpleHttpResponse> callback)
|
| public final Future | |
| public abstract IOReactorStatus | |
| public abstract void | |
| public abstract void | |
| public final void | |
| public abstract void |
| CloseableHttpAsyncClient | back to summary |
|---|---|
| public CloseableHttpAsyncClient() | |
| awaitShutdown | back to summary |
|---|---|
| public abstract void awaitShutdown(TimeValue waitTime) throws InterruptedException | |
| doExecute | back to summary |
|---|---|
| protected abstract <T> Future | |
| execute | back to summary |
|---|---|
| public final <T> Future | |
| execute | back to summary |
|---|---|
| public final <T> Future Implements org. Doc from org. Initiates asynchronous HTTP request execution using the given context. The request producer passed to this method will be used to generate a request message and stream out its content without buffering it in memory. The response consumer passed to this method will be used to process a response message without buffering its content in memory. Please note it may be unsafe to interact with the context instance while the request is still being executed.
| |
| execute | back to summary |
|---|---|
| public final <T> Future | |
| execute | back to summary |
|---|---|
| public final <T> Future | |
| execute | back to summary |
|---|---|
| public final Future | |
| execute | back to summary |
|---|---|
| public final Future | |
| getStatus | back to summary |
|---|---|
| public abstract IOReactorStatus getStatus() | |
| initiateShutdown | back to summary |
|---|---|
| public abstract void initiateShutdown() | |
| register | back to summary |
|---|---|
| public abstract void register(String hostname, String uriPattern, Supplier<AsyncPushConsumer> supplier) | |
| register | back to summary |
|---|---|
| public final void register(final String uriPattern, final Supplier<AsyncPushConsumer> supplier) | |
| start | back to summary |
|---|---|
| public abstract void start() | |