Package org.apache.cassandra.net
Class AsyncOneResponse<T>
- java.lang.Object
-
- org.apache.cassandra.net.AsyncPromise<T>
-
- org.apache.cassandra.net.AsyncOneResponse<T>
-
- All Implemented Interfaces:
io.netty.util.concurrent.Future<T>
,io.netty.util.concurrent.Promise<T>
,java.util.concurrent.Future<T>
,RequestCallback<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.
-
-
Constructor Summary
Constructors Constructor Description AsyncOneResponse()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> AsyncOneResponse<T>
immediate(T value)
void
onResponse(Message<T> response)
-
Methods inherited from class org.apache.cassandra.net.AsyncPromise
addListener, addListeners, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, get, get, getNow, isCancellable, isCancelled, isDone, isSuccess, removeListener, removeListeners, setFailure, setSuccess, setUncancellable, sync, syncUninterruptibly, toString, tryFailure, trySuccess, uncancellable, uncancellable
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.cassandra.net.RequestCallback
invokeOnFailure, onFailure, trackLatencyForSnitch
-
-
-
-
Method Detail
-
onResponse
public void onResponse(Message<T> response)
- Specified by:
onResponse
in interfaceRequestCallback<T>
- Parameters:
response
- response received.
-
immediate
public static <T> AsyncOneResponse<T> immediate(T value)
-
-