Package | Description |
---|---|
org.apache.http.concurrent |
Core concurrency APIs.
|
org.apache.http.impl.nio.pool |
Default implementations of client side connection pools
for asynchronous, even driven communication.
|
org.apache.http.nio.pool |
Client side connection pools APIs for asynchronous, event driven
communication.
|
org.apache.http.nio.protocol |
Core HTTP protocol execution framework and HTTP protocol handlers
for asynchronous, event driven communication.
|
org.apache.http.pool |
Client side connection pools APIs for synchronous, blocking
communication.
|
Modifier and Type | Field and Description |
---|---|
private FutureCallback<T> |
BasicFuture.callback |
Constructor and Description |
---|
BasicFuture(FutureCallback<T> callback) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<BasicNIOPoolEntry> |
BasicNIOConnPool.lease(HttpHost route,
java.lang.Object state,
FutureCallback<BasicNIOPoolEntry> callback) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<E> |
AbstractNIOConnPool.lease(T route,
java.lang.Object state,
FutureCallback<E> callback) |
java.util.concurrent.Future<E> |
AbstractNIOConnPool.lease(T route,
java.lang.Object state,
long connectTimeout,
long leaseTimeout,
java.util.concurrent.TimeUnit tunit,
FutureCallback<E> callback) |
java.util.concurrent.Future<E> |
AbstractNIOConnPool.lease(T route,
java.lang.Object state,
long connectTimeout,
java.util.concurrent.TimeUnit tunit,
FutureCallback<E> callback) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
HttpAsyncRequester.ConnPipelinedRequestCallback<T,E extends PoolEntry<HttpHost,NHttpClientConnection>> |
(package private) class |
HttpAsyncRequester.ConnRequestCallback<T,E extends PoolEntry<HttpHost,NHttpClientConnection>> |
(package private) class |
HttpAsyncRequester.RequestExecutionCallback<T,E extends PoolEntry<HttpHost,NHttpClientConnection>> |
Modifier and Type | Method and Description |
---|---|
<T,E extends PoolEntry<HttpHost,NHttpClientConnection>> |
HttpAsyncRequester.execute(HttpAsyncRequestProducer requestProducer,
HttpAsyncResponseConsumer<T> responseConsumer,
ConnPool<HttpHost,E> connPool,
HttpContext context,
FutureCallback<T> callback)
Initiates asynchronous HTTP request execution.
|
<T,E extends PoolEntry<HttpHost,NHttpClientConnection>> |
HttpAsyncRequester.execute(HttpAsyncRequestProducer requestProducer,
HttpAsyncResponseConsumer<T> responseConsumer,
E poolEntry,
ConnPool<HttpHost,E> connPool,
HttpContext context,
FutureCallback<T> callback)
Initiates asynchronous HTTP request execution.
|
<T> java.util.concurrent.Future<T> |
HttpAsyncRequester.execute(HttpAsyncRequestProducer requestProducer,
HttpAsyncResponseConsumer<T> responseConsumer,
NHttpClientConnection conn,
HttpContext context,
FutureCallback<T> callback)
Initiates asynchronous HTTP request execution.
|
<T,E extends PoolEntry<HttpHost,NHttpClientConnection>> |
HttpAsyncRequester.executePipelined(HttpHost target,
java.util.List<? extends HttpAsyncRequestProducer> requestProducers,
java.util.List<? extends HttpAsyncResponseConsumer<T>> responseConsumers,
ConnPool<HttpHost,E> connPool,
HttpContext context,
FutureCallback<java.util.List<T>> callback)
Initiates asynchronous pipelined HTTP request execution.
|
<T,E extends PoolEntry<HttpHost,NHttpClientConnection>> |
HttpAsyncRequester.executePipelined(java.util.List<HttpAsyncRequestProducer> requestProducers,
java.util.List<HttpAsyncResponseConsumer<T>> responseConsumers,
E poolEntry,
ConnPool<HttpHost,E> connPool,
HttpContext context,
FutureCallback<java.util.List<T>> callback)
Initiates asynchronous pipelined HTTP request execution.
|
Constructor and Description |
---|
BasicAsyncClientExchangeHandler(HttpAsyncRequestProducer requestProducer,
HttpAsyncResponseConsumer<T> responseConsumer,
FutureCallback<T> callback,
HttpContext localContext,
NHttpClientConnection conn,
HttpProcessor httppocessor,
ConnectionReuseStrategy connReuseStrategy)
Creates new instance of BasicAsyncRequestExecutionHandler.
|
BasicAsyncRequestExecutionHandler(HttpAsyncRequestProducer requestProducer,
HttpAsyncResponseConsumer<T> responseConsumer,
FutureCallback<T> callback,
HttpContext localContext,
HttpProcessor httppocessor,
ConnectionReuseStrategy reuseStrategy,
HttpParams params)
Deprecated.
|
PipeliningClientExchangeHandler(java.util.List<? extends HttpAsyncRequestProducer> requestProducers,
java.util.List<? extends HttpAsyncResponseConsumer<T>> responseConsumers,
FutureCallback<java.util.List<T>> callback,
HttpContext localContext,
NHttpClientConnection conn,
HttpProcessor httppocessor,
ConnectionReuseStrategy connReuseStrategy)
Creates new instance of
PipeliningClientExchangeHandler . |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<E> |
AbstractConnPool.lease(T route,
java.lang.Object state,
FutureCallback<E> callback)
Attempts to lease a connection for the given route and with the given
state from the pool.
|
java.util.concurrent.Future<E> |
ConnPool.lease(T route,
java.lang.Object state,
FutureCallback<E> callback)
Attempts to lease a connection for the given route and with the given
state from the pool.
|