Uses of Interface
org.eclipse.jetty.util.Promise.Invocable

Packages that use Promise.Invocable

Package	Description
org.eclipse.jetty.http	Jetty Http : Tools for Http processing
org.eclipse.jetty.http3
org.eclipse.jetty.http3.api
org.eclipse.jetty.http3.client
org.eclipse.jetty.quic.api
org.eclipse.jetty.quic.common
org.eclipse.jetty.quic.quiche	This module contains the main abstractions for the QUIC protocol using the Quiche library.
org.eclipse.jetty.server	Jetty Server : Core Server API
org.eclipse.jetty.util	Jetty Util : Common Utility Classes

Uses of Promise.Invocable in org.eclipse.jetty.http

Methods in org.eclipse.jetty.http with parameters of type Promise.Invocable

Modifier and Type	Method	Description
static void	MultiPartFormData.onParts(Content.Source content, Attributes attributes, String contentType, MultiPartConfig config, Promise.Invocable<MultiPartFormData.Parts> promise)	Asynchronously get multipart/form-data MultiPartFormData.Parts from a Content.Source, caching the results in an Attributes.
void	MultiPartFormData.Parser.parse(Content.Source content, Promise.Invocable<MultiPartFormData.Parts> promise)
void	MultiPartFormData.Parser.parse(Content.Source content, Promise<MultiPartFormData.Parts> immediate, Promise.Invocable<MultiPartFormData.Parts> future)	Deprecated, for removal: This API element is subject to removal in a future version. use MultiPartFormData.Parser.parse(Content.Source, Promise.Invocable) or MultiPartFormData.onParts(Content.Source, Attributes, String, MultiPartConfig, Promise.Invocable) instead.

Uses of Promise.Invocable in org.eclipse.jetty.http3

Methods in org.eclipse.jetty.http3 with parameters of type Promise.Invocable

Modifier and Type	Method	Description
void	HTTP3Session.close(long error, String reason, Promise.Invocable<Session> promise)	Called when an external event wants to initiate the close of this session locally, for example a close at the network level (due to e.g. stopping a component) or a timeout.
void	HTTP3Stream.data(DataFrame frame, Promise.Invocable<Stream> promise)
void	HTTP3Stream.disconnect(long appErrorCode, Throwable failure, Promise.Invocable<Stream> promise)
void	HTTP3Session.goAway(boolean graceful, Promise.Invocable<Session> promise)
void	HTTP3Stream.trailer(HeadersFrame frame, Promise.Invocable<Stream> promise)
protected void	HTTP3Stream.write(Frame frame, Promise.Invocable<Stream> promise)
void	HTTP3Stream.writeFrame(Frame frame, Promise.Invocable<Stream> promise)

Uses of Promise.Invocable in org.eclipse.jetty.http3.api

Methods in org.eclipse.jetty.http3.api with parameters of type Promise.Invocable

Modifier and Type	Method	Description
void	Stream.data(DataFrame frame, Promise.Invocable<Stream> promise)	Sends the given DATA frame containing some or all the bytes of the request content or of the response content.
void	Stream.disconnect(long appErrorCode, Throwable failure, Promise.Invocable<Stream> promise)	Abruptly terminates this stream with the given error.
default void	Session.goAway(boolean graceful, Promise.Invocable<Session> promise)	Initiates the shutdown of this session by sending a GOAWAY frame to the other peer.
void	Session.Client.newRequest(HeadersFrame frame, Stream.Client.Listener listener, Promise.Invocable<Stream> promise)	Makes a request by creating an HTTP/3 stream and sending the given HEADERS frame.
void	Stream.Server.respond(HeadersFrame frame, Promise.Invocable<Stream> promise)	Responds to a request performed via Session.Client.newRequest(HeadersFrame, Client.Listener, Promise.Invocable), sending the given HEADERS frame containing the response status code and response headers.
void	Stream.trailer(HeadersFrame frame, Promise.Invocable<Stream> promise)	Sends the given HEADERS frame containing the trailer headers.

Uses of Promise.Invocable in org.eclipse.jetty.http3.client

Methods in org.eclipse.jetty.http3.client with parameters of type Promise.Invocable

Modifier and Type	Method	Description
void	HTTP3Client.connect(Transport transport, SocketAddress socketAddress, Session.Client.Listener listener, Promise.Invocable<Session.Client> promise)	Connect for HTTP/3, clear-text or intrinsically secure depending on the Transport.
void	HTTP3Client.connect(Transport transport, SslContextFactory.Client sslContextFactory, SocketAddress socketAddress, Session.Client.Listener listener, Map<String,Object> context, Promise.Invocable<Session.Client> promise)
void	HTTP3Client.connect(Transport transport, SslContextFactory.Client sslContextFactory, SocketAddress socketAddress, Session.Client.Listener listener, Promise.Invocable<Session.Client> promise)	Connect for HTTP/3, clear-text, or secure, or intrinsically secure depending on the Transport.
void	HTTP3SessionClient.newRequest(HeadersFrame frame, Stream.Client.Listener listener, Promise.Invocable<Stream> promise)

Constructors in org.eclipse.jetty.http3.client with parameters of type Promise.Invocable

Modifier	Constructor	Description
	HTTP3SessionClient(Scheduler scheduler, org.eclipse.jetty.http3.client.internal.ClientHTTP3Session session, Session.Client.Listener listener, Promise.Invocable<Session.Client> promise)

Uses of Promise.Invocable in org.eclipse.jetty.quic.api

Methods in org.eclipse.jetty.quic.api with parameters of type Promise.Invocable

Modifier and Type	Method	Description
void	Session.close(ConnectionCloseFrame frame, Promise.Invocable<Session> promise)	Closes this session with the given CONNECTION_CLOSE frame.
void	Stream.data(boolean last, List<ByteBuffer> data, Promise.Invocable<Stream> promise)	Sends a STREAM frame with the given data bytes and the indication of whether they are the last to be sent.
void	Stream.dataBlocked(long offset, Promise.Invocable<Stream> promise)	Sends a STREAM_DATA_BLOCKED frame, with the given offset.
void	Session.disconnect(ConnectionCloseFrame frame, Throwable failure, Promise.Invocable<Session> promise)	Disconnects this session, with the given CONNECTION_CLOSE and failure cause, if any.
void	Stream.disconnect(long appErrorCode, Throwable failure, Promise.Invocable<Stream> promise)	Abruptly terminates this stream with the given error.
void	Session.maxData(MaxDataFrame frame, Promise.Invocable<Session> promise)	Sends a MAX_DATA frame on this connection.
void	Stream.maxData(long maxData, Promise.Invocable<Stream> promise)	Sends a MAX_STREAM_DATA frame with the new total max data bytes that this peer is willing to receive.
void	Session.maxStreams(MaxStreamsFrame frame, Promise.Invocable<Session> promise)	Sends a MAX_STREAMS frame on this connection.
default void	Stream.Listener.onIdleTimeout(Stream stream, TimeoutException failure, Promise.Invocable<Boolean> promise)	Invoked when the stream is idle for longer than the idle timeout.
void	Session.ping(Promise.Invocable<Session> promise)	Sends a PING frame on this connection.
void	Stream.reset(long appErrorCode, Promise.Invocable<Stream> promise)	Sends a RESET_STREAM frame, with the given application error code.
void	Stream.stopSending(long appErrorCode, Promise.Invocable<Stream> promise)	Sends a STOP_SENDING frame, with the given application error code.

Uses of Promise.Invocable in org.eclipse.jetty.quic.common

Methods in org.eclipse.jetty.quic.common with parameters of type Promise.Invocable

Modifier and Type	Method	Description
void	AbstractSession.close(ConnectionCloseFrame frame, Promise.Invocable<Session> promise)
void	ProtocolSession.close(ConnectionCloseFrame frame, Promise.Invocable<ProtocolSession> promise)	Performs an inward close upon sending a CONNECTION_CLOSE frame.
void	ProtocolSession.disconnect(ConnectionCloseFrame frame, Throwable failure, Promise.Invocable<ProtocolSession> promise)	Performs an outward disconnection.
void	StreamEndPoint.disconnect(long appError, Throwable failure, boolean disconnectStream, Promise.Invocable<StreamEndPoint> promise)
protected void	AbstractSession.notifyLocalClose(ConnectionCloseFrame frame, Promise.Invocable<Session> promise)
void	ProtocolStreamListener.onIdleTimeout(Stream stream, TimeoutException failure, Promise.Invocable<Boolean> promise)
void	AbstractSession.Listener.onLocalClose(Session session, ConnectionCloseFrame frame, Promise.Invocable<Session> promise)
void	StreamEndPoint.shutdownOutput(long appError, Promise.Invocable<StreamEndPoint> promise)

Uses of Promise.Invocable in org.eclipse.jetty.quic.quiche

Methods in org.eclipse.jetty.quic.quiche with parameters of type Promise.Invocable

Modifier and Type	Method	Description
void	QuicheStream.data(boolean last, List<ByteBuffer> buffers, Promise.Invocable<Stream> promise)
void	QuicheStream.dataBlocked(long offset, Promise.Invocable<Stream> promise)
void	QuicheSession.disconnect(ConnectionCloseFrame frame, Throwable failure, Promise.Invocable<Session> promise)
void	QuicheStream.disconnect(long appErrorCode, Throwable failure, Promise.Invocable<Stream> promise)
void	QuicheSession.maxData(MaxDataFrame frame, Promise.Invocable<Session> promise)
void	QuicheStream.maxData(long maxData, Promise.Invocable<Stream> promise)
void	QuicheSession.maxStreams(MaxStreamsFrame frame, Promise.Invocable<Session> promise)
void	QuicheSession.ping(Promise.Invocable<Session> promise)
void	QuicheStream.reset(long appErrorCode, Promise.Invocable<Stream> promise)
void	QuicheStream.stopSending(long appErrorCode, Promise.Invocable<Stream> promise)

Uses of Promise.Invocable in org.eclipse.jetty.server

Methods in org.eclipse.jetty.server with parameters of type Promise.Invocable

Modifier and Type	Method	Description
static void	FormFields.onFields(Request request, Charset charset, int maxFields, int maxLength, Promise.Invocable<Fields> promise)	Asynchronously reads and parses FormFields from a Request.
static void	FormFields.onFields(Request request, Charset charset, Promise.Invocable<Fields> promise)	Asynchronously read and parse FormFields from a Request.
static void	FormFields.onFields(Request request, Promise.Invocable<Fields> promise)	Asynchronously read and parse FormFields from a Request.
static void	Request.onParameters(Request request, Promise.Invocable<Fields> promise)	Asynchronous version of Request.getParameters(Request).

Uses of Promise.Invocable in org.eclipse.jetty.util

Subinterfaces of Promise.Invocable in org.eclipse.jetty.util

Modifier and Type	Interface	Description
static interface	Blocker.Promise<C>

Classes in org.eclipse.jetty.util that implement Promise.Invocable

Modifier and Type	Class	Description
static class	Promise.Invocable.Abstract<T>	Abstract implementation of Promise.Invocable with the specified Invocable.InvocationType.
static class	Promise.Invocable.NonBlocking<T>	Abstract implementation of Promise.Invocable with Invocable.InvocationType set to Invocable.InvocationType.NON_BLOCKING.

Methods in org.eclipse.jetty.util that return Promise.Invocable

Modifier and Type	Method	Description
static <T> Promise.Invocable<T>	Promise.Invocable.from(Runnable beforeComplete, Promise.Invocable<T> promise)	Returns a promise that, when it is completed, runs the given Runnable and then completes the given promise.
static <T> Promise.Invocable<T>	Promise.Invocable.from(Promise.Invocable<T> promise, Runnable afterComplete)	Returns a promise that, when it is completed, completes the given promise and then runs the given Runnable.
static <T> Promise.Invocable<T>	Promise.Invocable.from(Invocable.InvocationType invocationType, BiConsumer<T,Throwable> consumer)	Factory method to create a promise from the given arguments.
static <T> Promise.Invocable<T>	Promise.Invocable.from(Invocable.InvocationType invocationType, Consumer<T> success, Consumer<Throwable> failure)	Factory method to create a promise from the given arguments.
static <T> Promise.Invocable<T>	Promise.Invocable.noop()
static <W> Promise.Invocable<W>	Promise.Invocable.toPromise(CompletableFuture<W> completable)	Returns a new promise that, when it is completed, completes the given CompletableFuture.
static <W, T> Promise.Invocable<W>	Promise.Invocable.toPromise(Promise.Invocable<T> promise, Function<W,T> mapper)	Returns a new promise that, when it is completed, completes the given promise.

Methods in org.eclipse.jetty.util with parameters of type Promise.Invocable

Modifier and Type	Method	Description
static <T> Promise.Invocable<T>	Promise.Invocable.from(Runnable beforeComplete, Promise.Invocable<T> promise)	Returns a promise that, when it is completed, runs the given Runnable and then completes the given promise.
static <T> Promise.Invocable<T>	Promise.Invocable.from(Promise.Invocable<T> promise, Runnable afterComplete)	Returns a promise that, when it is completed, completes the given promise and then runs the given Runnable.
static <R> BiConsumer<R,Throwable>	Promise.Invocable.toBiConsumer(Promise.Invocable<R> promise)	Returns a BiConsumer that, when it is invoked, completes the given promise
static <T> Callback	Promise.Invocable.toCallback(Promise.Invocable<T> promise, T result)	Returns a new Callback that, when it is completed, completes the given promise.
static <W, T> Promise.Invocable<W>	Promise.Invocable.toPromise(Promise.Invocable<T> promise, Function<W,T> mapper)	Returns a new promise that, when it is completed, completes the given promise.