Uses of Interface
org.apache.hc.core5.concurrent.FutureCallback
-
Packages that use FutureCallback 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 -
-
Uses of FutureCallback in org.apache.hc.core5.concurrent
Classes in org.apache.hc.core5.concurrent that implement FutureCallback Modifier and Type Class Description class
CallbackContribution<T>
Convenience base class forFutureCallback
s that contribute a result of the operation to anotherFutureCallback
.class
FutureContribution<T>
Convenience base class forFutureCallback
s that contribute a result of the operation to anotherBasicFuture
.Fields in org.apache.hc.core5.concurrent declared as FutureCallback Modifier and Type Field Description private FutureCallback<T>
BasicFuture. callback
private FutureCallback<?>
CallbackContribution. callback
Constructors in org.apache.hc.core5.concurrent with parameters of type FutureCallback Constructor Description BasicFuture(FutureCallback<T> callback)
CallbackContribution(FutureCallback<?> callback)
ComplexFuture(FutureCallback<T> callback)
-
Uses of FutureCallback in org.apache.hc.core5.http.impl.bootstrap
Methods in org.apache.hc.core5.http.impl.bootstrap with parameters of type FutureCallback Modifier and Type Method Description java.util.concurrent.Future<IOSession>
AbstractConnectionInitiatorBase. connect(NamedEndpoint remoteEndpoint, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, Timeout timeout, java.lang.Object attachment, FutureCallback<IOSession> callback)
java.util.concurrent.Future<AsyncClientEndpoint>
HttpAsyncRequester. connect(HttpHost host, Timeout timeout, java.lang.Object attachment, FutureCallback<AsyncClientEndpoint> callback)
protected java.util.concurrent.Future<AsyncClientEndpoint>
HttpAsyncRequester. doConnect(HttpHost host, Timeout timeout, java.lang.Object attachment, FutureCallback<AsyncClientEndpoint> callback)
protected void
HttpAsyncRequester. doTlsUpgrade(ProtocolIOSession ioSession, NamedEndpoint endpoint, FutureCallback<ProtocolIOSession> callback)
<T> java.util.concurrent.Future<T>
HttpAsyncRequester. execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, Timeout timeout, HttpContext context, FutureCallback<T> callback)
<T> java.util.concurrent.Future<T>
HttpAsyncRequester. execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, Timeout timeout, FutureCallback<T> callback)
<T> java.util.concurrent.Future<T>
HttpAsyncRequester. execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, Timeout timeout, HttpContext context, FutureCallback<T> callback)
java.util.concurrent.Future<ListenerEndpoint>
AsyncServer. listen(java.net.SocketAddress address, java.lang.Object attachment, FutureCallback<ListenerEndpoint> callback)
java.util.concurrent.Future<ListenerEndpoint>
AsyncServer. listen(java.net.SocketAddress address, FutureCallback<ListenerEndpoint> callback)
java.util.concurrent.Future<ListenerEndpoint>
HttpAsyncServer. listen(java.net.SocketAddress address, FutureCallback<ListenerEndpoint> callback)
Deprecated.java.util.concurrent.Future<ListenerEndpoint>
HttpAsyncServer. listen(java.net.SocketAddress address, URIScheme scheme, java.lang.Object attachment, FutureCallback<ListenerEndpoint> callback)
java.util.concurrent.Future<ListenerEndpoint>
HttpAsyncServer. listen(java.net.SocketAddress address, URIScheme scheme, FutureCallback<ListenerEndpoint> callback)
java.util.concurrent.Future<IOSession>
AsyncRequester. requestSession(HttpHost host, Timeout timeout, java.lang.Object attachment, FutureCallback<IOSession> callback)
void
HttpAsyncRequester.InternalAsyncClientEndpoint. tlsUpgrade(NamedEndpoint endpoint, FutureCallback<ProtocolIOSession> callback)
-
Uses of FutureCallback in org.apache.hc.core5.http.nio
Methods in org.apache.hc.core5.http.nio with parameters of type FutureCallback Modifier and Type Method 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> java.util.concurrent.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> java.util.concurrent.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> java.util.concurrent.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. -
Uses of FutureCallback in org.apache.hc.core5.http.nio.entity
Fields in org.apache.hc.core5.http.nio.entity declared as FutureCallback Modifier and Type Field Description private FutureCallback<T>
AbstractBinAsyncEntityConsumer. resultCallback
private FutureCallback<T>
AbstractCharAsyncEntityConsumer. resultCallback
private FutureCallback<T>
DiscardingEntityConsumer. resultCallback
private FutureCallback<java.lang.Void>
NoopEntityConsumer. resultCallback
Deprecated.Methods in org.apache.hc.core5.http.nio.entity with parameters of type FutureCallback Modifier and Type Method Description void
AbstractBinAsyncEntityConsumer. streamStart(EntityDetails entityDetails, FutureCallback<T> resultCallback)
void
AbstractCharAsyncEntityConsumer. streamStart(EntityDetails entityDetails, FutureCallback<T> resultCallback)
void
DigestingEntityConsumer. streamStart(EntityDetails entityDetails, FutureCallback<T> resultCallback)
void
DiscardingEntityConsumer. streamStart(EntityDetails entityDetails, FutureCallback<T> resultCallback)
void
NoopEntityConsumer. streamStart(EntityDetails entityDetails, FutureCallback<java.lang.Void> resultCallback)
Deprecated. -
Uses of FutureCallback in org.apache.hc.core5.http.nio.ssl
Methods in org.apache.hc.core5.http.nio.ssl with parameters of type FutureCallback Modifier and Type Method Description void
TlsUpgradeCapable. tlsUpgrade(NamedEndpoint endpoint, FutureCallback<ProtocolIOSession> callback)
void
BasicClientTlsStrategy. upgrade(TransportSecurityLayer tlsSession, NamedEndpoint endpoint, java.lang.Object attachment, Timeout handshakeTimeout, FutureCallback<TransportSecurityLayer> callback)
void
BasicServerTlsStrategy. upgrade(TransportSecurityLayer tlsSession, NamedEndpoint endpoint, java.lang.Object attachment, Timeout handshakeTimeout, FutureCallback<TransportSecurityLayer> callback)
default void
TlsStrategy. upgrade(TransportSecurityLayer sessionLayer, NamedEndpoint endpoint, java.lang.Object attachment, Timeout handshakeTimeout, FutureCallback<TransportSecurityLayer> callback)
Secures current session layer with TLS. -
Uses of FutureCallback in org.apache.hc.core5.http.nio.support
Fields in org.apache.hc.core5.http.nio.support declared as FutureCallback Modifier and Type Field Description private FutureCallback<T>
BasicClientExchangeHandler. resultCallback
Methods in org.apache.hc.core5.http.nio.support with parameters of type FutureCallback Modifier and Type Method Description void
AbstractAsyncRequesterConsumer. consumeRequest(HttpRequest request, EntityDetails entityDetails, HttpContext httpContext, FutureCallback<T> resultCallback)
void
BasicRequestConsumer. consumeRequest(HttpRequest request, EntityDetails entityDetails, HttpContext httpContext, FutureCallback<Message<HttpRequest,T>> resultCallback)
void
AbstractAsyncResponseConsumer. consumeResponse(HttpResponse response, EntityDetails entityDetails, HttpContext httpContext, FutureCallback<T> resultCallback)
void
BasicResponseConsumer. consumeResponse(HttpResponse response, EntityDetails entityDetails, HttpContext httpContext, FutureCallback<Message<HttpResponse,T>> resultCallback)
Constructors in org.apache.hc.core5.http.nio.support with parameters of type FutureCallback Constructor Description BasicClientExchangeHandler(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, FutureCallback<T> resultCallback)
-
Uses of FutureCallback in org.apache.hc.core5.http.nio.support.classic
Methods in org.apache.hc.core5.http.nio.support.classic with parameters of type FutureCallback Modifier and Type Method Description void
AbstractClassicEntityConsumer. streamStart(EntityDetails entityDetails, FutureCallback<T> resultCallback)
-
Uses of FutureCallback in org.apache.hc.core5.http2.impl.nio
Fields in org.apache.hc.core5.http2.impl.nio declared as FutureCallback Modifier and Type Field Description private FutureCallback<ProtocolIOSession>
HttpProtocolNegotiator. resultCallback
private FutureCallback<ProtocolIOSession>
PrefaceHandlerBase. resultCallback
Methods in org.apache.hc.core5.http2.impl.nio with parameters of type FutureCallback Modifier and Type Method Description void
ClientH2UpgradeHandler. upgrade(ProtocolIOSession ioSession, FutureCallback<ProtocolIOSession> callback)
void
ClientHttp1UpgradeHandler. upgrade(ProtocolIOSession ioSession, FutureCallback<ProtocolIOSession> callback)
void
ServerH2UpgradeHandler. upgrade(ProtocolIOSession ioSession, FutureCallback<ProtocolIOSession> callback)
void
ServerHttp1UpgradeHandler. upgrade(ProtocolIOSession ioSession, FutureCallback<ProtocolIOSession> callback)
Constructors in org.apache.hc.core5.http2.impl.nio with parameters of type FutureCallback Constructor Description ClientH2PrefaceHandler(ProtocolIOSession ioSession, ClientH2StreamMultiplexerFactory http2StreamHandlerFactory, boolean strictALPNHandshake, FutureCallback<ProtocolIOSession> resultCallback)
HttpProtocolNegotiator(ProtocolIOSession ioSession, FutureCallback<ProtocolIOSession> resultCallback)
PrefaceHandlerBase(ProtocolIOSession ioSession, FutureCallback<ProtocolIOSession> resultCallback)
ServerH2PrefaceHandler(ProtocolIOSession ioSession, ServerH2StreamMultiplexerFactory http2StreamHandlerFactory, FutureCallback<ProtocolIOSession> resultCallback)
-
Uses of FutureCallback in org.apache.hc.core5.http2.impl.nio.bootstrap
Methods in org.apache.hc.core5.http2.impl.nio.bootstrap with parameters of type FutureCallback Modifier and Type Method Description protected java.util.concurrent.Future<AsyncClientEndpoint>
H2AsyncRequester. doConnect(HttpHost host, Timeout timeout, java.lang.Object attachment, FutureCallback<AsyncClientEndpoint> callback)
protected void
H2AsyncRequester. doTlsUpgrade(ProtocolIOSession ioSession, NamedEndpoint endpoint, FutureCallback<ProtocolIOSession> callback)
<T> java.util.concurrent.Future<T>
H2MultiplexingRequester. execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, Timeout timeout, HttpContext context, FutureCallback<T> callback)
<T> java.util.concurrent.Future<T>
H2MultiplexingRequester. execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, Timeout timeout, FutureCallback<T> callback)
<T> java.util.concurrent.Future<T>
H2MultiplexingRequester. execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, Timeout timeout, HttpContext context, FutureCallback<T> callback)
-
Uses of FutureCallback in org.apache.hc.core5.http2.nio.pool
Methods in org.apache.hc.core5.http2.nio.pool with parameters of type FutureCallback Modifier and Type Method Description protected java.util.concurrent.Future<IOSession>
H2ConnPool. connectSession(HttpHost namedEndpoint, Timeout connectTimeout, FutureCallback<IOSession> callback)
-
Uses of FutureCallback in org.apache.hc.core5.http2.ssl
Methods in org.apache.hc.core5.http2.ssl with parameters of type FutureCallback Modifier and Type Method Description void
H2ClientTlsStrategy. upgrade(TransportSecurityLayer tlsSession, NamedEndpoint endpoint, java.lang.Object attachment, Timeout handshakeTimeout, FutureCallback<TransportSecurityLayer> callback)
void
H2ServerTlsStrategy. upgrade(TransportSecurityLayer tlsSession, NamedEndpoint endpoint, java.lang.Object attachment, Timeout handshakeTimeout, FutureCallback<TransportSecurityLayer> callback)
-
Uses of FutureCallback in org.apache.hc.core5.pool
Methods in org.apache.hc.core5.pool with parameters of type FutureCallback Modifier and Type Method Description java.util.concurrent.Future<PoolEntry<T,C>>
ConnPool. lease(T route, java.lang.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.java.util.concurrent.Future<PoolEntry<T,C>>
LaxConnPool. lease(T route, java.lang.Object state, Timeout requestTimeout, FutureCallback<PoolEntry<T,C>> callback)
java.util.concurrent.Future<PoolEntry<T,C>>
LaxConnPool.PerRoutePool. lease(java.lang.Object state, Timeout requestTimeout, FutureCallback<PoolEntry<T,C>> callback)
java.util.concurrent.Future<PoolEntry<T,C>>
StrictConnPool. lease(T route, java.lang.Object state, Timeout requestTimeout, FutureCallback<PoolEntry<T,C>> callback)
-
Uses of FutureCallback in org.apache.hc.core5.reactive
Methods in org.apache.hc.core5.reactive with parameters of type FutureCallback Modifier and Type Method Description void
ReactiveResponseConsumer. consumeResponse(HttpResponse response, EntityDetails entityDetails, HttpContext httpContext, FutureCallback<java.lang.Void> resultCallback)
Constructors in org.apache.hc.core5.reactive with parameters of type FutureCallback Constructor Description ReactiveResponseConsumer(FutureCallback<Message<HttpResponse,org.reactivestreams.Publisher<java.nio.ByteBuffer>>> responseCallback)
Creates aReactiveResponseConsumer
that will call back the suppliedFutureCallback
with a streamable response. -
Uses of FutureCallback in org.apache.hc.core5.reactor
Fields in org.apache.hc.core5.reactor with type parameters of type FutureCallback Modifier and Type Field Description (package private) java.util.Queue<FutureCallback<IOSession>>
AbstractIOSessionPool.PoolEntry. requestQueue
Methods in org.apache.hc.core5.reactor with parameters of type FutureCallback Modifier and Type Method Description java.util.concurrent.Future<IOSession>
AbstractIOReactorBase. connect(NamedEndpoint remoteEndpoint, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, Timeout timeout, java.lang.Object attachment, FutureCallback<IOSession> callback)
java.util.concurrent.Future<IOSession>
ConnectionInitiator. connect(NamedEndpoint remoteEndpoint, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, Timeout timeout, java.lang.Object attachment, FutureCallback<IOSession> callback)
Requests a connection to a remote host.java.util.concurrent.Future<IOSession>
SingleCoreIOReactor. connect(NamedEndpoint remoteEndpoint, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, Timeout timeout, java.lang.Object attachment, FutureCallback<IOSession> callback)
protected abstract java.util.concurrent.Future<IOSession>
AbstractIOSessionPool. connectSession(T namedEndpoint, Timeout connectTimeout, FutureCallback<IOSession> callback)
java.util.concurrent.Future<IOSession>
AbstractIOSessionPool. getSession(T endpoint, Timeout connectTimeout, FutureCallback<IOSession> callback)
private void
AbstractIOSessionPool. getSessionInternal(AbstractIOSessionPool.PoolEntry poolEntry, boolean requestNew, T namedEndpoint, Timeout connectTimeout, FutureCallback<IOSession> callback)
default java.util.concurrent.Future<ListenerEndpoint>
ConnectionAcceptor. listen(java.net.SocketAddress address, java.lang.Object attachment, FutureCallback<ListenerEndpoint> callback)
Opens a new listener endpoint with the given socket address.java.util.concurrent.Future<ListenerEndpoint>
ConnectionAcceptor. listen(java.net.SocketAddress address, FutureCallback<ListenerEndpoint> callback)
Opens a new listener endpoint with the given socket address.java.util.concurrent.Future<ListenerEndpoint>
DefaultListeningIOReactor. listen(java.net.SocketAddress address, java.lang.Object attachment, FutureCallback<ListenerEndpoint> callback)
java.util.concurrent.Future<ListenerEndpoint>
DefaultListeningIOReactor. listen(java.net.SocketAddress address, FutureCallback<ListenerEndpoint> callback)
java.util.concurrent.Future<ListenerEndpoint>
SingleCoreListeningIOReactor. listen(java.net.SocketAddress address, java.lang.Object attachment, FutureCallback<ListenerEndpoint> callback)
java.util.concurrent.Future<ListenerEndpoint>
SingleCoreListeningIOReactor. listen(java.net.SocketAddress address, FutureCallback<ListenerEndpoint> callback)
void
InternalDataChannel. startTls(javax.net.ssl.SSLContext sslContext, NamedEndpoint endpoint, SSLBufferMode sslBufferMode, SSLSessionInitializer initializer, SSLSessionVerifier verifier, Timeout handshakeTimeout, FutureCallback<TransportSecurityLayer> callback)
void
InternalDataChannel. switchProtocol(java.lang.String protocolId, FutureCallback<ProtocolIOSession> callback)
default void
ProtocolIOSession. switchProtocol(java.lang.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.Constructors in org.apache.hc.core5.reactor with parameters of type FutureCallback Constructor Description IOSessionRequest(NamedEndpoint remoteEndpoint, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, Timeout timeout, java.lang.Object attachment, FutureCallback<IOSession> callback)
-
Uses of FutureCallback in org.apache.hc.core5.reactor.ssl
Fields in org.apache.hc.core5.reactor.ssl with type parameters of type FutureCallback Modifier and Type Field Description private java.util.concurrent.atomic.AtomicReference<FutureCallback<javax.net.ssl.SSLSession>>
SSLIOSession. handshakeCallbackRef
Methods in org.apache.hc.core5.reactor.ssl with parameters of type FutureCallback Modifier and Type Method Description default void
TransportSecurityLayer. startTls(javax.net.ssl.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.Constructors in org.apache.hc.core5.reactor.ssl with parameters of type FutureCallback Constructor Description SSLIOSession(NamedEndpoint targetEndpoint, IOSession session, SSLMode sslMode, javax.net.ssl.SSLContext sslContext, SSLBufferMode sslBufferMode, SSLSessionInitializer initializer, SSLSessionVerifier verifier, Timeout handshakeTimeout, Callback<SSLIOSession> sessionStartCallback, Callback<SSLIOSession> sessionEndCallback, FutureCallback<javax.net.ssl.SSLSession> resultCallback)
Creates new instance ofSSLIOSession
class. -
Uses of FutureCallback in org.apache.hc.core5.testing.nio
Methods in org.apache.hc.core5.testing.nio with parameters of type FutureCallback Modifier and Type Method Description java.util.concurrent.Future<IOSession>
AsyncRequester. connect(NamedEndpoint remoteEndpoint, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, Timeout timeout, java.lang.Object attachment, FutureCallback<IOSession> callback)
java.util.concurrent.Future<ClientSessionEndpoint>
H2TestClient. connect(HttpHost host, Timeout timeout, FutureCallback<ClientSessionEndpoint> callback)
java.util.concurrent.Future<ClientSessionEndpoint>
Http1TestClient. connect(HttpHost host, Timeout timeout, FutureCallback<ClientSessionEndpoint> callback)
<T> java.util.concurrent.Future<T>
ClientSessionEndpoint. execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, FutureCallback<T> callback)
<T> java.util.concurrent.Future<T>
ClientSessionEndpoint. execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context, FutureCallback<T> callback)
<T> java.util.concurrent.Future<T>
ClientSessionEndpoint. execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HttpContext context, FutureCallback<T> callback)
java.util.concurrent.Future<IOSession>
AsyncRequester. requestSession(HttpHost host, Timeout timeout, FutureCallback<IOSession> callback)
-