| Package | Description |
|---|---|
| org.apache.hc.core5.concurrent |
Core concurrency component APIs.
|
| org.apache.hc.core5.http.impl.bootstrap |
HTTP/1.1 requester and server bootstrap.
|
| org.apache.hc.core5.http.nio |
Core HTTP transport APIs based on the asynchronous, event driven I/O model.
|
| org.apache.hc.core5.http.nio.entity |
HTTP message entity APIs based on the asynchronous (non-blocking) I/O model.
|
| org.apache.hc.core5.http.nio.ssl |
TLS protocol support.
|
| org.apache.hc.core5.http.nio.support |
Support classes for the asynchronous I/O model.
|
| org.apache.hc.core5.http.nio.support.classic |
Support classes for the asynchronous I/O model that emulate
behavior of the classic (blocking) I/O model.
|
| org.apache.hc.core5.http2.impl.nio |
Default implementation of HTTP/2 transport based on
the asynchronous (non-blocking) I/O model.
|
| org.apache.hc.core5.http2.impl.nio.bootstrap |
HTTP/2 capable requester and server bootstrap.
|
| org.apache.hc.core5.http2.nio.pool |
HTTP/2 specific pool component APIs.
|
| org.apache.hc.core5.http2.ssl |
HTTP/2 specific TLS protocol support.
|
| org.apache.hc.core5.pool |
Client side connection pool component APIs.
|
| org.apache.hc.core5.reactive | |
| org.apache.hc.core5.reactor |
Event driven network communication APIs and components loosely based on
Doug Lea's
reactor pattern.
|
| org.apache.hc.core5.reactor.ssl |
TLS/SSL support for I/O reactors.
|
| org.apache.hc.core5.testing.nio |
| Modifier and Type | Class and Description |
|---|---|
class |
CallbackContribution<T>
Convenience base class for
FutureCallbacks that contribute a result
of the operation to another FutureCallback. |
class |
FutureContribution<T>
Convenience base class for
FutureCallbacks that contribute a result
of the operation to another BasicFuture. |
| Constructor and Description |
|---|
BasicFuture(FutureCallback<T> callback) |
CallbackContribution(FutureCallback<?> callback) |
ComplexFuture(FutureCallback<T> callback) |
| Modifier and Type | Method and Description |
|---|---|
void |
AsyncRequestConsumer.consumeRequest(HttpRequest request,
EntityDetails entityDetails,
HttpContext context,
FutureCallback<T> resultCallback)
Triggered to signal receipt of a request message head.
|
void |
AsyncResponseConsumer.consumeResponse(HttpResponse response,
EntityDetails entityDetails,
HttpContext context,
FutureCallback<T> resultCallback)
Triggered to signal receipt of a response message head.
|
<T> Future<T> |
AsyncClientEndpoint.execute(AsyncRequestProducer requestProducer,
AsyncResponseConsumer<T> responseConsumer,
FutureCallback<T> callback)
Initiates a message exchange using the given request producer and response consumer.
|
<T> Future<T> |
AsyncClientEndpoint.execute(AsyncRequestProducer requestProducer,
AsyncResponseConsumer<T> responseConsumer,
HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
HttpContext context,
FutureCallback<T> callback)
Initiates message exchange using the given request producer and response consumer.
|
<T> Future<T> |
AsyncClientEndpoint.execute(AsyncRequestProducer requestProducer,
AsyncResponseConsumer<T> responseConsumer,
HttpContext context,
FutureCallback<T> callback)
Initiates message exchange using the given request producer and response consumer.
|
void |
AsyncEntityConsumer.streamStart(EntityDetails entityDetails,
FutureCallback<T> resultCallback)
Signals beginning of an incoming request entity stream.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractBinAsyncEntityConsumer.streamStart(EntityDetails entityDetails,
FutureCallback<T> resultCallback) |
void |
DiscardingEntityConsumer.streamStart(EntityDetails entityDetails,
FutureCallback<T> resultCallback) |
void |
AbstractCharAsyncEntityConsumer.streamStart(EntityDetails entityDetails,
FutureCallback<T> resultCallback) |
void |
DigestingEntityConsumer.streamStart(EntityDetails entityDetails,
FutureCallback<T> resultCallback) |
void |
NoopEntityConsumer.streamStart(EntityDetails entityDetails,
FutureCallback<Void> resultCallback)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TlsUpgradeCapable.tlsUpgrade(NamedEndpoint endpoint,
FutureCallback<ProtocolIOSession> callback) |
void |
BasicClientTlsStrategy.upgrade(TransportSecurityLayer tlsSession,
NamedEndpoint endpoint,
Object attachment,
Timeout handshakeTimeout,
FutureCallback<TransportSecurityLayer> callback) |
default void |
TlsStrategy.upgrade(TransportSecurityLayer sessionLayer,
NamedEndpoint endpoint,
Object attachment,
Timeout handshakeTimeout,
FutureCallback<TransportSecurityLayer> callback)
Secures current session layer with TLS.
|
void |
BasicServerTlsStrategy.upgrade(TransportSecurityLayer tlsSession,
NamedEndpoint endpoint,
Object attachment,
Timeout handshakeTimeout,
FutureCallback<TransportSecurityLayer> callback) |
| Modifier and Type | Method and Description |
|---|---|
void |
BasicRequestConsumer.consumeRequest(HttpRequest request,
EntityDetails entityDetails,
HttpContext httpContext,
FutureCallback<Message<HttpRequest,T>> resultCallback) |
void |
AbstractAsyncRequesterConsumer.consumeRequest(HttpRequest request,
EntityDetails entityDetails,
HttpContext httpContext,
FutureCallback<T> resultCallback) |
void |
BasicResponseConsumer.consumeResponse(HttpResponse response,
EntityDetails entityDetails,
HttpContext httpContext,
FutureCallback<Message<HttpResponse,T>> resultCallback) |
void |
AbstractAsyncResponseConsumer.consumeResponse(HttpResponse response,
EntityDetails entityDetails,
HttpContext httpContext,
FutureCallback<T> resultCallback) |
| Constructor and Description |
|---|
BasicClientExchangeHandler(AsyncRequestProducer requestProducer,
AsyncResponseConsumer<T> responseConsumer,
FutureCallback<T> resultCallback) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractClassicEntityConsumer.streamStart(EntityDetails entityDetails,
FutureCallback<T> resultCallback) |
| Modifier and Type | Method and Description |
|---|---|
void |
ServerHttp1UpgradeHandler.upgrade(ProtocolIOSession ioSession,
FutureCallback<ProtocolIOSession> callback) |
void |
ClientHttp1UpgradeHandler.upgrade(ProtocolIOSession ioSession,
FutureCallback<ProtocolIOSession> callback) |
void |
ClientH2UpgradeHandler.upgrade(ProtocolIOSession ioSession,
FutureCallback<ProtocolIOSession> callback) |
void |
ServerH2UpgradeHandler.upgrade(ProtocolIOSession ioSession,
FutureCallback<ProtocolIOSession> callback) |
| Constructor and Description |
|---|
ClientH2PrefaceHandler(ProtocolIOSession ioSession,
ClientH2StreamMultiplexerFactory http2StreamHandlerFactory,
boolean strictALPNHandshake,
FutureCallback<ProtocolIOSession> resultCallback) |
HttpProtocolNegotiator(ProtocolIOSession ioSession,
FutureCallback<ProtocolIOSession> resultCallback) |
ServerH2PrefaceHandler(ProtocolIOSession ioSession,
ServerH2StreamMultiplexerFactory http2StreamHandlerFactory,
FutureCallback<ProtocolIOSession> resultCallback) |
| Modifier and Type | Method and Description |
|---|---|
protected Future<AsyncClientEndpoint> |
H2AsyncRequester.doConnect(HttpHost host,
Timeout timeout,
Object attachment,
FutureCallback<AsyncClientEndpoint> callback) |
protected void |
H2AsyncRequester.doTlsUpgrade(ProtocolIOSession ioSession,
NamedEndpoint endpoint,
FutureCallback<ProtocolIOSession> callback) |
<T> Future<T> |
H2MultiplexingRequester.execute(AsyncRequestProducer requestProducer,
AsyncResponseConsumer<T> responseConsumer,
HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
Timeout timeout,
HttpContext context,
FutureCallback<T> callback) |
<T> Future<T> |
H2MultiplexingRequester.execute(AsyncRequestProducer requestProducer,
AsyncResponseConsumer<T> responseConsumer,
Timeout timeout,
FutureCallback<T> callback) |
<T> Future<T> |
H2MultiplexingRequester.execute(AsyncRequestProducer requestProducer,
AsyncResponseConsumer<T> responseConsumer,
Timeout timeout,
HttpContext context,
FutureCallback<T> callback) |
| Modifier and Type | Method and Description |
|---|---|
protected Future<IOSession> |
H2ConnPool.connectSession(HttpHost namedEndpoint,
Timeout connectTimeout,
FutureCallback<IOSession> callback) |
| Modifier and Type | Method and Description |
|---|---|
void |
H2ServerTlsStrategy.upgrade(TransportSecurityLayer tlsSession,
NamedEndpoint endpoint,
Object attachment,
Timeout handshakeTimeout,
FutureCallback<TransportSecurityLayer> callback) |
void |
ConscryptServerTlsStrategy.upgrade(TransportSecurityLayer tlsSession,
NamedEndpoint endpoint,
Object attachment,
Timeout handshakeTimeout,
FutureCallback<TransportSecurityLayer> callback) |
void |
H2ClientTlsStrategy.upgrade(TransportSecurityLayer tlsSession,
NamedEndpoint endpoint,
Object attachment,
Timeout handshakeTimeout,
FutureCallback<TransportSecurityLayer> callback) |
void |
ConscryptClientTlsStrategy.upgrade(TransportSecurityLayer tlsSession,
NamedEndpoint endpoint,
Object attachment,
Timeout handshakeTimeout,
FutureCallback<TransportSecurityLayer> callback) |
| Modifier and Type | Method and Description |
|---|---|
Future<PoolEntry<T,C>> |
LaxConnPool.lease(T route,
Object state,
Timeout requestTimeout,
FutureCallback<PoolEntry<T,C>> callback) |
Future<PoolEntry<T,C>> |
StrictConnPool.lease(T route,
Object state,
Timeout requestTimeout,
FutureCallback<PoolEntry<T,C>> callback) |
Future<PoolEntry<T,C>> |
ConnPool.lease(T route,
Object state,
Timeout requestTimeout,
FutureCallback<PoolEntry<T,C>> callback)
Attempts to lease a connection for the given route and with the given
state from the pool.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ReactiveResponseConsumer.consumeResponse(HttpResponse response,
EntityDetails entityDetails,
HttpContext httpContext,
FutureCallback<Void> resultCallback) |
| Constructor and Description |
|---|
ReactiveResponseConsumer(FutureCallback<Message<HttpResponse,org.reactivestreams.Publisher<ByteBuffer>>> responseCallback)
Creates a
ReactiveResponseConsumer that will call back the supplied FutureCallback with a
streamable response. |
| Modifier and Type | Method and Description |
|---|---|
Future<IOSession> |
ConnectionInitiator.connect(NamedEndpoint remoteEndpoint,
SocketAddress remoteAddress,
SocketAddress localAddress,
Timeout timeout,
Object attachment,
FutureCallback<IOSession> callback)
Requests a connection to a remote host.
|
protected abstract Future<IOSession> |
AbstractIOSessionPool.connectSession(T namedEndpoint,
Timeout connectTimeout,
FutureCallback<IOSession> callback) |
Future<IOSession> |
AbstractIOSessionPool.getSession(T endpoint,
Timeout connectTimeout,
FutureCallback<IOSession> callback) |
Future<ListenerEndpoint> |
ConnectionAcceptor.listen(SocketAddress address,
FutureCallback<ListenerEndpoint> callback)
Opens a new listener endpoint with the given socket address.
|
Future<ListenerEndpoint> |
DefaultListeningIOReactor.listen(SocketAddress address,
FutureCallback<ListenerEndpoint> callback) |
default Future<ListenerEndpoint> |
ConnectionAcceptor.listen(SocketAddress address,
Object attachment,
FutureCallback<ListenerEndpoint> callback)
Opens a new listener endpoint with the given socket address.
|
Future<ListenerEndpoint> |
DefaultListeningIOReactor.listen(SocketAddress address,
Object attachment,
FutureCallback<ListenerEndpoint> callback) |
default void |
ProtocolIOSession.switchProtocol(String protocolId,
FutureCallback<ProtocolIOSession> callback)
Switches this I/O session to the application protocol with the given ID.
|
void |
ProtocolUpgradeHandler.upgrade(ProtocolIOSession ioSession,
FutureCallback<ProtocolIOSession> callback)
Upgrades application protocol of the given I/O session.
|
| Modifier and Type | Method and Description |
|---|---|
default void |
TransportSecurityLayer.startTls(SSLContext sslContext,
NamedEndpoint endpoint,
SSLBufferMode sslBufferMode,
SSLSessionInitializer initializer,
SSLSessionVerifier verifier,
Timeout handshakeTimeout,
FutureCallback<TransportSecurityLayer> callback)
Starts TLS session over an existing network connection with the given SSL context.
|
| Constructor and Description |
|---|
SSLIOSession(NamedEndpoint targetEndpoint,
IOSession session,
SSLMode sslMode,
SSLContext sslContext,
SSLBufferMode sslBufferMode,
SSLSessionInitializer initializer,
SSLSessionVerifier verifier,
Timeout handshakeTimeout,
Callback<SSLIOSession> sessionStartCallback,
Callback<SSLIOSession> sessionEndCallback,
FutureCallback<SSLSession> resultCallback)
Creates new instance of
SSLIOSession class. |
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.