Class ManagedChannelImpl.UncommittedRetriableStreamsRegistry

java.lang.Object
io.grpc.internal.ManagedChannelImpl.UncommittedRetriableStreamsRegistry
Enclosing class:
ManagedChannelImpl

private final class ManagedChannelImpl.UncommittedRetriableStreamsRegistry extends Object
A registry that prevents channel shutdown from killing existing retry attempts that are in backoff.
  • Field Details

  • Constructor Details

    • UncommittedRetriableStreamsRegistry

      private UncommittedRetriableStreamsRegistry()
  • Method Details

    • onShutdown

      void onShutdown(Status reason)
    • onShutdownNow

      void onShutdownNow(Status reason)
    • add

      @Nullable Status add(RetriableStream<?> retriableStream)
      Registers a RetriableStream and return null if not shutdown, otherwise just returns the shutdown Status.
    • remove

      void remove(RetriableStream<?> retriableStream)