Package | Description |
---|---|
org.eclipse.jetty.client |
Jetty Client : Implementation and Core Classes
This package provides APIs, utility classes and an implementation of an asynchronous HTTP client.
|
org.eclipse.jetty.client.api |
Jetty Client : API Classes
|
org.eclipse.jetty.client.http | |
org.eclipse.jetty.fcgi.client.http | |
org.eclipse.jetty.http2 | |
org.eclipse.jetty.http2.api | |
org.eclipse.jetty.http2.client | |
org.eclipse.jetty.http2.client.http | |
org.eclipse.jetty.proxy |
Jetty Proxy : Async Proxy Support
|
org.eclipse.jetty.util |
Jetty Util : Common Utility Classes
|
Modifier and Type | Class and Description |
---|---|
private class |
HttpProxy.CreateTunnelPromise
Creates a tunnel using HTTP CONNECT.
|
private class |
HttpProxy.TunnelPromise |
Modifier and Type | Field and Description |
---|---|
private Promise<Connection> |
HttpProxy.CreateTunnelPromise.promise |
private Promise<Connection> |
HttpProxy.ProxyConnection.promise |
private Promise<Connection> |
HttpProxy.TunnelPromise.promise |
Modifier and Type | Method and Description |
---|---|
protected void |
HttpDestination.createConnection(Promise<Connection> promise) |
protected void |
HttpClient.newConnection(HttpDestination destination,
Promise<Connection> promise) |
void |
HttpDestination.newConnection(Promise<Connection> promise) |
Constructor and Description |
---|
CreateTunnelPromise(ClientConnectionFactory connectionFactory,
EndPoint endPoint,
Promise<Connection> promise,
java.util.Map<java.lang.String,java.lang.Object> context) |
ProxyConnection(Destination destination,
Connection connection,
Promise<Connection> promise) |
TunnelPromise(Request request,
Response.CompleteListener listener,
Promise<Connection> promise) |
Modifier and Type | Method and Description |
---|---|
void |
Destination.newConnection(Promise<Connection> promise)
Creates asynchronously a new, unpooled,
Connection that will be returned
at a later time through the given Promise . |
Modifier and Type | Field and Description |
---|---|
private Promise<Connection> |
HttpConnectionOverHTTP.promise |
Modifier and Type | Method and Description |
---|---|
protected HttpConnectionOverHTTP |
HttpClientTransportOverHTTP.newHttpConnection(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise) |
Constructor and Description |
---|
HttpConnectionOverHTTP(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise) |
Modifier and Type | Field and Description |
---|---|
private Promise<Connection> |
HttpConnectionOverFCGI.promise |
Modifier and Type | Method and Description |
---|---|
protected HttpConnectionOverFCGI |
HttpClientTransportOverFCGI.newHttpConnection(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise) |
Constructor and Description |
---|
HttpConnectionOverFCGI(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise,
boolean multiplexed) |
Modifier and Type | Field and Description |
---|---|
private Promise<Stream> |
HTTP2Session.StreamPromiseCallback.promise |
Modifier and Type | Method and Description |
---|---|
void |
HTTP2Session.newStream(HeadersFrame frame,
Promise<Stream> promise,
Stream.Listener listener) |
void |
ISession.push(IStream stream,
Promise<Stream> promise,
PushPromiseFrame frame,
Stream.Listener listener)
Enqueues the given PUSH_PROMISE frame to be written to the connection.
|
void |
HTTP2Session.push(IStream stream,
Promise<Stream> promise,
PushPromiseFrame frame,
Stream.Listener listener) |
void |
HTTP2Stream.push(PushPromiseFrame frame,
Promise<Stream> promise,
Stream.Listener listener) |
Constructor and Description |
---|
StreamPromiseCallback(Promise<Stream> promise,
IStream stream) |
Modifier and Type | Method and Description |
---|---|
void |
Session.newStream(HeadersFrame frame,
Promise<Stream> promise,
Stream.Listener listener)
Sends the given HEADERS
frame to create a new Stream . |
void |
Stream.push(PushPromiseFrame frame,
Promise<Stream> promise,
Stream.Listener listener)
Sends the given PUSH_PROMISE
frame . |
Modifier and Type | Field and Description |
---|---|
private Promise<Session> |
HTTP2ClientConnectionFactory.HTTP2ClientConnection.promise |
Modifier and Type | Method and Description |
---|---|
void |
HTTP2Client.accept(SslContextFactory sslContextFactory,
java.nio.channels.SocketChannel channel,
Session.Listener listener,
Promise<Session> promise) |
void |
HTTP2Client.connect(java.net.InetSocketAddress address,
Session.Listener listener,
Promise<Session> promise) |
void |
HTTP2Client.connect(SslContextFactory sslContextFactory,
java.net.InetSocketAddress address,
Session.Listener listener,
Promise<Session> promise) |
void |
HTTP2Client.connect(SslContextFactory sslContextFactory,
java.net.InetSocketAddress address,
Session.Listener listener,
Promise<Session> promise,
java.util.Map<java.lang.String,java.lang.Object> context) |
private java.util.Map<java.lang.String,java.lang.Object> |
HTTP2Client.contextFrom(SslContextFactory sslContextFactory,
java.net.InetSocketAddress address,
Session.Listener listener,
Promise<Session> promise,
java.util.Map<java.lang.String,java.lang.Object> context) |
Constructor and Description |
---|
HTTP2ClientConnection(HTTP2Client client,
ByteBufferPool byteBufferPool,
java.util.concurrent.Executor executor,
EndPoint endpoint,
Parser parser,
ISession session,
int bufferSize,
Promise<Session> promise,
Session.Listener listener) |
Modifier and Type | Class and Description |
---|---|
private class |
HttpClientTransportOverHTTP2.SessionListenerPromise |
Modifier and Type | Method and Description |
---|---|
private Promise<Connection> |
HttpClientTransportOverHTTP2.SessionListenerPromise.connectionPromise() |
Modifier and Type | Method and Description |
---|---|
protected void |
HttpClientTransportOverHTTP2.connect(SslContextFactory sslContextFactory,
java.net.InetSocketAddress address,
Session.Listener listener,
Promise<Session> promise,
java.util.Map<java.lang.String,java.lang.Object> context) |
Modifier and Type | Method and Description |
---|---|
protected void |
ConnectHandler.connectToServer(javax.servlet.http.HttpServletRequest request,
java.lang.String host,
int port,
Promise<java.nio.channels.SocketChannel> promise) |
Modifier and Type | Class and Description |
---|---|
class |
FuturePromise<C> |
static class |
Promise.Adapter<U>
Empty implementation of
Promise . |
static class |
Promise.Completable<S>
A CompletableFuture that is also a Promise.
|
static class |
Promise.Wrapper<W> |
Modifier and Type | Field and Description |
---|---|
private Promise<W> |
Promise.Wrapper.promise |
Modifier and Type | Method and Description |
---|---|
static <T> Promise<T> |
Promise.from(java.util.concurrent.CompletableFuture<? super T> completable)
Creates a promise from the given incomplete CompletableFuture.
|
Promise<W> |
Promise.Wrapper.getPromise() |
Promise<W> |
Promise.Wrapper.unwrap() |
Modifier and Type | Method and Description |
---|---|
void |
SocketAddressResolver.resolve(java.lang.String host,
int port,
Promise<java.util.List<java.net.InetSocketAddress>> promise)
Resolves the given host and port, returning a
SocketAddress through the given Promise
with the default timeout. |
void |
SocketAddressResolver.Sync.resolve(java.lang.String host,
int port,
Promise<java.util.List<java.net.InetSocketAddress>> promise) |
void |
SocketAddressResolver.Async.resolve(java.lang.String host,
int port,
Promise<java.util.List<java.net.InetSocketAddress>> promise) |
Constructor and Description |
---|
Wrapper(Promise<W> promise) |