Class RetriableStream.FutureCanceller

java.lang.Object
io.grpc.internal.RetriableStream.FutureCanceller
Enclosing class:
RetriableStream<ReqT>

private static final class RetriableStream.FutureCanceller extends Object
Allows cancelling a Future without racing with setting the future.
  • Field Details

    • lock

      final Object lock
    • future

      Future<?> future
    • cancelled

      boolean cancelled
  • Constructor Details

    • FutureCanceller

      FutureCanceller(Object lock)
  • Method Details

    • setFuture

      void setFuture(Future<?> future)
    • markCancelled

      @CheckForNull Future<?> markCancelled()
    • isCancelled

      boolean isCancelled()