Uses of Interface
org.cometd.bayeux.Promise

Packages that use Promise

Package	Description
org.cometd.bayeux
org.cometd.bayeux.client
org.cometd.bayeux.server
org.cometd.client
org.cometd.client.http.jetty
org.cometd.client.http.okhttp
org.cometd.client.transport
org.cometd.common
org.cometd.server
org.cometd.server.http
org.cometd.server.websocket.common

Uses of Promise in org.cometd.bayeux

Classes in org.cometd.bayeux that implement Promise

Modifier and Type	Class and Description
static class	Promise.Completable<S> A CompletableFuture that is also a Promise.

Fields in org.cometd.bayeux declared as Promise

Modifier and Type	Field and Description
static Promise<?>	Promise.NOOP Shared instance whose methods are implemented empty, use noop() to ease type inference.

Methods in org.cometd.bayeux that return Promise

Modifier and Type	Method and Description
static <T> Promise<T>	Promise.complete(BiConsumer<T,Throwable> fn) Returns a Promise that, when completed, invokes the given BiConsumer function.
static <T> Promise<T>	Promise.from(Consumer<T> succeed, Consumer<Throwable> fail)
static <T> Promise<T>	Promise.noop()

Uses of Promise in org.cometd.bayeux.client

Methods in org.cometd.bayeux.client with parameters of type Promise

Modifier and Type	Method and Description
default void	ClientSession.Extension.incoming(ClientSession session, Message.Mutable message, Promise<Boolean> promise) Callback method invoked every time a message is incoming.
default void	ClientSession.Extension.outgoing(ClientSession session, Message.Mutable message, Promise<Boolean> promise) Callback method invoked every time a message is outgoing.

Uses of Promise in org.cometd.bayeux.server

Methods in org.cometd.bayeux.server with parameters of type Promise

Modifier and Type	Method and Description
default void	Authorizer.authorize(Authorizer.Operation operation, ChannelId channel, ServerSession session, ServerMessage message, Promise<Authorizer.Result> promise) Callback invoked to authorize the given operation on the given channel.
default void	SecurityPolicy.canCreate(BayeuxServer server, ServerSession session, String channelId, ServerMessage message, Promise<Boolean> promise) Checks if a message should be allowed to create a new channel.
default void	SecurityPolicy.canHandshake(BayeuxServer server, ServerSession session, ServerMessage message, Promise<Boolean> promise) Checks if a handshake message should be accepted.
default void	SecurityPolicy.canPublish(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message, Promise<Boolean> promise) Checks if a client can publish a message to a channel.
default void	SecurityPolicy.canSubscribe(BayeuxServer server, ServerSession session, ServerChannel channel, ServerMessage message, Promise<Boolean> promise) Checks if a subscribe message from a client is allowed to subscribe to a channel.
void	ServerSession.deliver(Session sender, ServerMessage.Mutable message, Promise<Boolean> promise) Delivers the given message to this session.
void	ServerSession.deliver(Session sender, String channel, Object data, Promise<Boolean> promise) Delivers the given information to this session.
default void	ServerSession.Extension.incoming(ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise) Callback method invoked every time a message is incoming.
default void	BayeuxServer.Extension.incoming(ServerSession from, ServerMessage.Mutable message, Promise<Boolean> promise) Callback method invoked every time a message is incoming.
default void	ServerChannel.MessageListener.onMessage(ServerSession sender, ServerChannel channel, ServerMessage.Mutable message, Promise<Boolean> promise) Callback invoked when a message is being published.
default void	ServerSession.MessageListener.onMessage(ServerSession session, ServerSession sender, ServerMessage message, Promise<Boolean> promise) Callback invoked when a message is sent.
default void	BayeuxServer.Extension.outgoing(ServerSession from, ServerSession to, ServerMessage.Mutable message, Promise<Boolean> promise) Callback method invoked every time a message is outgoing.
default void	ServerSession.Extension.outgoing(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise) Callback method invoked every time a message is outgoing.
void	ServerChannel.publish(Session from, Object data, Promise<Boolean> promise) Publishes the given information to this channel.
void	ServerChannel.publish(Session from, ServerMessage.Mutable message, Promise<Boolean> promise) Publishes the given message to this channel, delivering the message to all the ServerSessions subscribed to this channel.

Uses of Promise in org.cometd.client

Methods in org.cometd.client with parameters of type Promise

Modifier and Type	Method and Description
protected void	BayeuxClient.sendMessages(List<Message.Mutable> messages, Promise<Boolean> promise)

Uses of Promise in org.cometd.client.http.jetty

Methods in org.cometd.client.http.jetty with parameters of type Promise

Modifier and Type	Method and Description
protected void	JettyHttpClientTransport.customize(org.eclipse.jetty.client.api.Request request, Promise<org.eclipse.jetty.client.api.Request> promise)

Uses of Promise in org.cometd.client.http.okhttp

Methods in org.cometd.client.http.okhttp with parameters of type Promise

Modifier and Type	Method and Description
protected void	OkHttpClientTransport.customize(okhttp3.Request.Builder request, Promise<okhttp3.Request.Builder> promise)

Uses of Promise in org.cometd.client.transport

Methods in org.cometd.client.transport with parameters of type Promise

Modifier and Type	Method and Description
default void	TransportListener.onTimeout(List<? extends Message> messages, Promise<Long> promise) Callback method invoked when the send of a batch of messages expires before receiving a response from the server, controlled by the maxNetworkDelay option.

Uses of Promise in org.cometd.common

Methods in org.cometd.common with parameters of type Promise

Modifier and Type	Method and Description
protected void	AbstractClientSession.extendIncoming(Message.Mutable message, Promise<Boolean> promise)
protected void	AbstractClientSession.extendOutgoing(Message.Mutable message, Promise<Boolean> promise)
void	AbstractClientSession.receive(Message.Mutable message, Promise<Void> promise) Receives a message (from the server) and process it.
static <T,R> void	AsyncFoldLeft.reverseRun(List<T> list, R zero, AsyncFoldLeft.Operation<T,R> operation, Promise<R> promise) Processes, in reverse order, the given sequence of elements.
static <T,R> void	AsyncFoldLeft.run(Iterable<T> iterable, R zero, AsyncFoldLeft.Operation<T,R> operation, Promise<R> promise) Processes the given sequence of elements.
static <T,R> void	AsyncFoldLeft.run(T[] array, R zero, AsyncFoldLeft.Operation<T,R> operation, Promise<R> promise) Processes the given array of elements.

Uses of Promise in org.cometd.server

Methods in org.cometd.server that return Promise

Modifier and Type	Method and Description
protected Promise<Boolean>	BayeuxServerImpl.resolveLoop(AsyncFoldLeft.Loop<Boolean> loop)

Methods in org.cometd.server with parameters of type Promise

Modifier and Type	Method and Description
void	ServerSessionImpl.deliver(Session sender, ServerMessage.Mutable message, Promise<Boolean> promise)
void	ServerSessionImpl.deliver(Session sender, String channelId, Object data, Promise<Boolean> promise)
protected void	ServerSessionImpl.deliver1(ServerSession sender, ServerMessage.Mutable mutable, Promise<Boolean> promise)
protected void	ServerSessionImpl.extendIncoming(ServerMessage.Mutable message, Promise<Boolean> promise)
protected void	ServerSessionImpl.extendOutgoing(ServerSession sender, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
protected void	BayeuxServerImpl.extendOutgoing(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise)
void	BayeuxServerImpl.extendReply(ServerSessionImpl sender, ServerSessionImpl session, ServerMessage.Mutable reply, Promise<ServerMessage.Mutable> promise)
void	BayeuxServerImpl.handle(ServerSessionImpl session, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
void	AbstractServerTransport.processReply(ServerSessionImpl session, ServerMessage.Mutable reply, Promise<ServerMessage.Mutable> promise)
protected void	BayeuxServerImpl.publish(ServerSessionImpl session, ServerChannelImpl channel, ServerMessage.Mutable message, boolean receiving, Promise<Boolean> promise)
void	ServerChannelImpl.publish(Session from, Object data, Promise<Boolean> promise)
void	ServerChannelImpl.publish(Session from, ServerMessage.Mutable mutable, Promise<Boolean> promise)
void	LocalSessionImpl.receive(Message.Mutable message, Promise<Void> promise)

Uses of Promise in org.cometd.server.http

Methods in org.cometd.server.http that return Promise

Modifier and Type	Method and Description
Promise<Void>	AbstractHttpTransport.LongPollScheduler.getPromise()

Methods in org.cometd.server.http with parameters of type Promise

Modifier and Type	Method and Description
protected void	AbstractHttpTransport.flush(AbstractHttpTransport.Context context, Promise<Void> promise)
protected void	AbstractHttpTransport.handleMessage(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> promise)
protected AbstractHttpTransport.HttpScheduler	AbstractStreamHttpTransport.newHttpScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
protected AbstractHttpTransport.HttpScheduler	AsyncJSONTransport.newHttpScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable reply, long timeout)
protected void	AbstractStreamHttpTransport.process(AbstractHttpTransport.Context context, Promise<Void> promise)
protected void	AsyncJSONTransport.process(String json, AbstractHttpTransport.Context context, Promise<Void> promise)
protected void	AbstractHttpTransport.processMessages(AbstractHttpTransport.Context context, List<ServerMessage.Mutable> messages, Promise<Void> promise)
protected void	AbstractHttpTransport.resume(AbstractHttpTransport.Context context, ServerMessage.Mutable message, Promise<Void> promise)
protected AbstractHttpTransport.HttpScheduler	AbstractStreamHttpTransport.suspend(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
protected AbstractHttpTransport.HttpScheduler	AsyncJSONTransport.suspend(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
protected abstract AbstractHttpTransport.HttpScheduler	AbstractHttpTransport.suspend(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
protected void	AbstractStreamHttpTransport.write(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise)
protected void	AsyncJSONTransport.write(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise)
protected abstract void	AbstractHttpTransport.write(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise)

Constructors in org.cometd.server.http with parameters of type Promise

Constructor and Description
AbstractReader(AbstractHttpTransport.Context context, Promise<Void> promise)
CharsetReader(AbstractHttpTransport.Context context, Promise<Void> promise, Charset charset)
DispatchingLongPollScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
LongPollScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
UTF8Reader(AbstractHttpTransport.Context context, Promise<Void> promise)
Writer(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise)

Uses of Promise in org.cometd.server.websocket.common

Methods in org.cometd.server.websocket.common with parameters of type Promise

Modifier and Type	Method and Description
protected void	AbstractWebSocketEndPoint.flush(AbstractWebSocketEndPoint.Context context, Promise<Void> promise)
void	AbstractWebSocketEndPoint.onMessage(String data, Promise<Void> p)