Package io.grpc.internal
Class RetriableStream.FutureCanceller
- java.lang.Object
-
- io.grpc.internal.RetriableStream.FutureCanceller
-
- Enclosing class:
- RetriableStream<ReqT>
private static final class RetriableStream.FutureCanceller extends java.lang.Object
Allows cancelling a Future without racing with setting the future.
-
-
Constructor Summary
Constructors Constructor Description FutureCanceller(java.lang.Object lock)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) boolean
isCancelled()
(package private) java.util.concurrent.Future<?>
markCancelled()
(package private) void
setFuture(java.util.concurrent.Future<?> future)
-