Uses of Interface
org.apache.cassandra.utils.concurrent.Promise

Packages that use Promise

Package	Description
org.apache.cassandra.net
org.apache.cassandra.utils.concurrent

Uses of Promise in org.apache.cassandra.net

Classes in org.apache.cassandra.net that implement Promise

Modifier and Type	Class	Description
class	AsyncChannelPromise	See AsyncPromise and ChannelPromise This class is all boiler plate, just ensuring we return ourselves and invoke the correct Promise method.
class	AsyncOneResponse<T>	A callback specialized for returning a value from a single target; that is, this is for messages that we only send to one recipient.

Uses of Promise in org.apache.cassandra.utils.concurrent

Classes in org.apache.cassandra.utils.concurrent that implement Promise

Modifier and Type	Class	Description
class	AsyncPromise<V>	Extends AsyncFuture to implement the Promise interface.
static class	AsyncPromise.WithExecutor<V>
class	SyncPromise<V>	Extends SyncFuture to implement the Promise interface.
static class	SyncPromise.WithExecutor<V>

Methods in org.apache.cassandra.utils.concurrent that return Promise

Modifier and Type	Method	Description
Promise<V>	Promise.addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback)
Promise<V>	Promise.addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback, Executor executor)
Promise<V>	Promise.addCallback(Consumer<? super V> onSuccess, Consumer<? super Throwable> onFailure)
Promise<V>	Promise.addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> var1)
Promise<V>	Promise.addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... var1)
Promise<V>	Promise.await()	Wait indefinitely for this promise to complete, throwing any interrupt
Promise<V>	Promise.awaitThrowUncheckedOnInterrupt()	Wait indefinitely for this promise to complete, throwing any interrupt as an UncheckedInterruptedException
Promise<V>	Promise.awaitUninterruptibly()	Wait indefinitely for this promise to complete
Promise<V>	Promise.removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> var1)
Promise<V>	Promise.removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... var1)
Promise<V>	AsyncPromise.setFailure(Throwable throwable)	Complete the promise abnormally if not already complete
Promise<V>	Promise.setFailure(Throwable throwable)	Complete the promise abnormally if not already complete
Promise<V>	SyncPromise.setFailure(Throwable throwable)	Complete the promise abnormally if not already complete
Promise<V>	AsyncPromise.setSuccess(V v)	Complete the promise successfully if not already complete
Promise<V>	Promise.setSuccess(V v)	Complete the promise successfully if not already complete
Promise<V>	SyncPromise.setSuccess(V v)	Complete the promise successfully if not already complete
Promise<V>	AsyncPromise.sync()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces
Promise<V>	Promise.sync()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces
Promise<V>	SyncPromise.sync()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces
Promise<V>	AsyncPromise.syncUninterruptibly()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces
Promise<V>	Promise.syncUninterruptibly()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces
Promise<V>	SyncPromise.syncUninterruptibly()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces