Package org.apache.cassandra.net

Class AsyncOneResponse<T>

java.lang.Object

org.apache.cassandra.utils.concurrent.AbstractFuture<V>

org.apache.cassandra.utils.concurrent.AsyncFuture<V>

org.apache.cassandra.utils.concurrent.AsyncPromise<T>

org.apache.cassandra.net.AsyncOneResponse<T>

All Implemented Interfaces:

com.google.common.util.concurrent.ListenableFuture<T>, io.netty.util.concurrent.Future<T>, io.netty.util.concurrent.Promise<T>, Future<T>, RequestCallback<T>, Awaitable, Future<T>, Promise<T>

public class AsyncOneResponse<T>
extends AsyncPromise<T>
implements RequestCallback<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.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.utils.concurrent.AsyncPromise

AsyncPromise.WithExecutor<V>

Nested classes/interfaces inherited from interface org.apache.cassandra.utils.concurrent.Awaitable

Awaitable.AbstractAwaitable, Awaitable.AsyncAwaitable, Awaitable.Defaults, Awaitable.SyncAwaitable

Field Summary

Fields inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture

CANCELLED, UNCANCELLABLE, UNSET

Constructor Summary

Constructors

Constructor	Description
AsyncOneResponse()

Method Summary

Modifier and Type	Method	Description
static <T> AsyncOneResponse<T>	immediate(T value)
void	onResponse(Message<T> response)

Methods inherited from class org.apache.cassandra.utils.concurrent.AsyncPromise

addCallback, addCallback, addCallback, addListener, addListeners, await, awaitThrowUncheckedOnInterrupt, awaitUninterruptibly, isUncancellable, removeListener, removeListeners, setFailure, setSuccess, setUncancellable, setUncancellableExclusive, sync, syncUninterruptibly, tryFailure, trySuccess, uncancellable, uncancellable, uncancellable, withExecutor

Methods inherited from class org.apache.cassandra.utils.concurrent.AsyncFuture

awaitUntil, flatMap, map

Methods inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture

addCallback, addCallback, addCallback, addListener, addListener, await, awaitThrowUncheckedOnInterrupt, awaitUninterruptibly, awaitUntilThrowUncheckedOnInterrupt, awaitUntilUninterruptibly, cancel, cause, description, flatMap, get, get, getNow, getWhenDone, isCancellable, isCancelled, isDone, isSuccess, map, map, notifyExecutor, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.cassandra.utils.concurrent.Awaitable

await, awaitThrowUncheckedOnInterrupt, awaitUninterruptibly, awaitUntil, awaitUntilThrowUncheckedOnInterrupt, awaitUntilUninterruptibly

Methods inherited from interface io.netty.util.concurrent.Future

await, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccess

Methods inherited from interface java.util.concurrent.Future

get, get, isCancelled, isDone

Methods inherited from interface org.apache.cassandra.utils.concurrent.Future

addCallback, addCallback, addCallback, addListener, addListener, await, awaitUninterruptibly, flatMap, flatMap, map, map, notifyExecutor, rethrowIfFailed, syncThrowUncheckedOnInterrupt

Methods inherited from interface org.apache.cassandra.net.RequestCallback

invokeOnFailure, onFailure, trackLatencyForSnitch

Constructor Details

AsyncOneResponse

public AsyncOneResponse()

Method Details

onResponse

public void onResponse(Message<T> response)

Specified by:

onResponse in interface RequestCallback<T>

Parameters:

response - response received.

immediate

public static <T> AsyncOneResponse<T> immediate(T value)