Searched defs:retryAlgorithm (Results 1 – 10 of 10) sorted by relevance
60 private final RetryAlgorithm<ResponseT> retryAlgorithm; field in ScheduledRetryingExecutor71 RetryAlgorithm<ResponseT> retryAlgorithm, ScheduledExecutorService scheduler) { in ScheduledRetryingExecutor()
51 private final RetryAlgorithm<ResponseT> retryAlgorithm; field in DirectRetryingExecutor60 public DirectRetryingExecutor(RetryAlgorithm<ResponseT> retryAlgorithm) { in DirectRetryingExecutor()
62 private final RetryAlgorithm<ResponseT> retryAlgorithm; field in BasicRetryingFuture74 RetryAlgorithm<ResponseT> retryAlgorithm, in BasicRetryingFuture()
60 RetryAlgorithm<ResponseT> retryAlgorithm, in CallbackChainRetryingFuture()
67 RetryAlgorithm<Integer> retryAlgorithm = mock(RetryAlgorithm.class); in testHandleAttemptDoesNotThrowNPEWhenLogLevelLowerThanFiner() local108 RetryAlgorithm<Integer> retryAlgorithm = mock(RetryAlgorithm.class); in testUsesRetryingContext() local
63 protected RetryingExecutorWithContext<String> getExecutor(RetryAlgorithm<String> retryAlgorithm) { in getExecutor()76 RetryAlgorithm<String> retryAlgorithm, ScheduledExecutorService scheduler) { in getRetryingExecutor()
40 protected RetryingExecutorWithContext<String> getExecutor(RetryAlgorithm<String> retryAlgorithm) { in getExecutor()
88 RetryAlgorithm<String> retryAlgorithm); in getExecutor()
70 RetryAlgorithm<ResponseT> retryAlgorithm = in retrying() local95 StreamingRetryAlgorithm<Void> retryAlgorithm = in retrying() local
72 RetryAlgorithm<V> retryAlgorithm = new RetryAlgorithm<>(resultAlgorithm, timedAlgorithm); in run() local