Class RetryPolicy


  • public final class RetryPolicy
    extends Object
    Retry policy for SDK communication to Dapr API.
    • Constructor Detail

      • RetryPolicy

        public RetryPolicy()
      • RetryPolicy

        public RetryPolicy​(Integer maxRetries)
    • Method Detail

      • apply

        public <T> reactor.core.publisher.Mono<T> apply​(reactor.core.publisher.Mono<T> response)
        Applies the retry policy to an expected Mono action.
        Type Parameters:
        T - Type expected for the action's response
        Parameters:
        response - Response
        Returns:
        action with retry
      • apply

        public <T> reactor.core.publisher.Flux<T> apply​(reactor.core.publisher.Flux<T> response)
        Applies the retry policy to an expected Flux action.
        Type Parameters:
        T - Type expected for the action's response
        Parameters:
        response - Response
        Returns:
        action with retry