Uses of Interface
org.cometd.bayeux.Promise
Packages that use Promise
Package
Description
-
Uses of Promise in org.cometd.bayeux
Classes in org.cometd.bayeux that implement PromiseModifier and TypeClassDescriptionstatic class
A CompletableFuture that is also a Promise.Fields in org.cometd.bayeux declared as PromiseModifier and TypeFieldDescriptionstatic final Promise<?>
Promise.NOOP
Shared instance whose methods are implemented empty,Methods in org.cometd.bayeux that return PromiseModifier and TypeMethodDescriptionstatic <T> Promise<T>
Promise.complete
(BiConsumer<T, Throwable> fn) Returns a Promise that, when completed, invokes the givenBiConsumer
function.static <T> Promise<T>
static <T> Promise<T>
Promise.noop()
-
Uses of Promise in org.cometd.bayeux.client
Methods in org.cometd.bayeux.client with parameters of type PromiseModifier and TypeMethodDescriptiondefault 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 PromiseModifier and TypeMethodDescriptiondefault void
Authorizer.authorize
(Authorizer.Operation operation, ChannelId channel, ServerSession session, ServerMessage message, Promise<Authorizer.Result> promise) Callback invoked to authorize the givenoperation
on the givenchannel
.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
Delivers the given information to this session.void
ServerSession.deliver
(Session sender, ServerMessage.Mutable message, Promise<Boolean> promise) Delivers the given message to this session.default void
BayeuxServer.Extension.incoming
(ServerSession from, ServerMessage.Mutable message, Promise<Boolean> promise) Callback method invoked every time a message is incoming.default void
ServerSession.Extension.incoming
(ServerSession session, 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
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 theServerSession
s subscribed to this channel. -
Uses of Promise in org.cometd.client
Methods in org.cometd.client with parameters of type PromiseModifier and TypeMethodDescriptionprotected 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 -
Uses of Promise in org.cometd.client.http.okhttp
Methods in org.cometd.client.http.okhttp with parameters of type Promise -
Uses of Promise in org.cometd.client.transport
Methods in org.cometd.client.transport with parameters of type Promise -
Uses of Promise in org.cometd.common
Methods in org.cometd.common with parameters of type PromiseModifier and TypeMethodDescriptionprotected 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 PromiseMethods in org.cometd.server with parameters of type PromiseModifier and TypeMethodDescriptionvoid
void
ServerSessionImpl.deliver
(Session sender, ServerMessage.Mutable message, 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
BayeuxServerImpl.extendOutgoing
(ServerSession sender, ServerSession session, ServerMessage.Mutable message, Promise<Boolean> promise) protected void
ServerSessionImpl.extendOutgoing
(ServerSession sender, ServerMessage.Mutable message, Promise<ServerMessage.Mutable> 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
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 PromiseMethods in org.cometd.server.http with parameters of type PromiseModifier and TypeMethodDescriptionprotected 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 abstract AbstractHttpTransport.HttpScheduler
AbstractHttpTransport.suspend
(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout) 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 void
AbstractHttpTransport.write
(AbstractHttpTransport.Context context, List<ServerMessage> messages, Promise<Void> promise) 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) Constructors in org.cometd.server.http with parameters of type PromiseModifierConstructorDescriptionprotected
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) protected
LongPollScheduler
(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout) protected
UTF8Reader
(AbstractHttpTransport.Context context, Promise<Void> promise) protected
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