com.google.cloud.bigtable.grpc.async
Class AbstractRetryingOperation.GrpcFuture<RespT>
- java.lang.Object
-
- com.google.common.util.concurrent.internal.InternalFutureFailureAccess
-
- com.google.common.util.concurrent.AbstractFuture<RespT>
-
- com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation.GrpcFuture<RespT>
-
- All Implemented Interfaces:
- ListenableFuture<RespT>, Future<RespT>
- Enclosing class:
- AbstractRetryingOperation<RequestT,ResponseT,ResultT>
protected class AbstractRetryingOperation.GrpcFuture<RespT> extends AbstractFuture<RespT>
-
-
Constructor Summary
Constructors Modifier Constructor and Description protectedGrpcFuture()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description protected voidinterruptTask()This gets called fromFuture.cancel(boolean)for cancel(true).booleanset(RespT resp)booleansetException(Throwable throwable)-
Methods inherited from class com.google.common.util.concurrent.AbstractFuture
addListener, afterDone, cancel, get, get, isCancelled, isDone, pendingToString, setFuture, toString, tryInternalFastPathGetFailure, wasInterrupted
-
-
-
-
Method Detail
-
interruptTask
protected void interruptTask()
This gets called fromFuture.cancel(boolean)for cancel(true). If a user explicitly cancels the Future, that should trigger a cancellation of the RPC.- Overrides:
interruptTaskin classAbstractFuture<RespT>
-
set
public boolean set(@Nullable RespT resp)- Overrides:
setin classAbstractFuture<RespT>
-
setException
public boolean setException(Throwable throwable)
- Overrides:
setExceptionin classAbstractFuture<RespT>
-
-