Class ManagedChannelImpl.UncommittedRetriableStreamsRegistry

  • Enclosing class:
    ManagedChannelImpl

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

      • lock

        final java.lang.Object lock
      • uncommittedRetriableStreams

        java.util.Collection<ClientStream> uncommittedRetriableStreams
      • shutdownStatus

        Status shutdownStatus
    • Constructor Detail

      • UncommittedRetriableStreamsRegistry

        private UncommittedRetriableStreamsRegistry()
    • Method Detail

      • 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.