Uses of Class
org.apache.cassandra.utils.concurrent.AsyncPromise

Packages that use AsyncPromise

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

Uses of AsyncPromise in org.apache.cassandra.net

Subclasses of AsyncPromise in org.apache.cassandra.net

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 AsyncPromise in org.apache.cassandra.utils.concurrent

Subclasses of AsyncPromise in org.apache.cassandra.utils.concurrent

Modifier and Type	Class	Description
static class	AsyncPromise.WithExecutor<V>

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

Modifier and Type	Method	Description
AsyncPromise<V>	AsyncPromise.addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback)
AsyncPromise<V>	AsyncPromise.addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback, Executor executor)
AsyncPromise<V>	AsyncPromise.addCallback(Consumer<? super V> onSuccess, Consumer<? super Throwable> onFailure)
AsyncPromise<V>	AsyncPromise.addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)
AsyncPromise<V>	AsyncPromise.addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... listeners)
AsyncPromise<V>	AsyncPromise.await()	Wait for this promise to complete
AsyncPromise<V>	AsyncPromise.awaitThrowUncheckedOnInterrupt()	Wait for this promise to complete, throwing any interrupt as an UncheckedInterruptedException
AsyncPromise<V>	AsyncPromise.awaitUninterruptibly()	Wait uninterruptibly for this promise to complete
AsyncPromise<V>	AsyncPromise.removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)
AsyncPromise<V>	AsyncPromise.removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... listeners)
static <V> AsyncPromise<V>	AsyncPromise.uncancellable()
static <V> AsyncPromise<V>	AsyncPromise.uncancellable(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)
static <V> AsyncPromise<V>	AsyncPromise.uncancellable(Executor executor)
static <V> AsyncPromise<V>	AsyncPromise.withExecutor(Executor executor)