Searched refs:ResultRetryAlgorithm (Results 1 – 9 of 9) sorted by relevance
24 import com.google.api.gax.retrying.ResultRetryAlgorithm;42 ResultRetryAlgorithm<?> resultRetryAlgorithm, in runWithRetries()49 ResultRetryAlgorithm<V> algorithm = (ResultRetryAlgorithm<V>) resultRetryAlgorithm; in runWithRetries()61 ResultRetryAlgorithm<V> resultPollAlgorithm, in poll()70 ResultRetryAlgorithm<V> resultAlgorithm) in run()
22 import com.google.api.gax.retrying.ResultRetryAlgorithm;37 public final class ExceptionHandler implements ResultRetryAlgorithm<Object>, Serializable {
49 new RetryAlgorithm<>(mock(ResultRetryAlgorithm.class), timedAlgorithm); in testCreateFirstAttempt()59 new RetryAlgorithm<>(mock(ResultRetryAlgorithm.class), timedAlgorithm); in testCreateFirstAttemptWithUnusedContext()89 ResultRetryAlgorithm<Object> resultAlgorithm = mock(ResultRetryAlgorithm.class); in testNextAttempt()119 ResultRetryAlgorithm<Object> resultAlgorithm = mock(ResultRetryAlgorithm.class); in testShouldRetry()133 ResultRetryAlgorithm<Object> resultAlgorithm = mock(ResultRetryAlgorithm.class); in testShouldRetry_usesTimedAlgorithm()181 ResultRetryAlgorithm<Object> resultAlgorithm = mock(ResultRetryAlgorithm.class); in testShouldRetry_noPreviousSettings()
32 import com.google.api.gax.retrying.ResultRetryAlgorithm;39 public class OperationResponsePollAlgorithm implements ResultRetryAlgorithm<OperationSnapshot> {
46 private final ResultRetryAlgorithm<ResponseT> resultAlgorithm;68 ResultRetryAlgorithm<ResponseT> resultAlgorithm, TimedRetryAlgorithm timedAlgorithm) { in RetryAlgorithm()259 public ResultRetryAlgorithm<ResponseT> getResultAlgorithm() { in getResultAlgorithm()
39 public interface ResultRetryAlgorithm<ResponseT> { interface
53 extends ResultRetryAlgorithm<ResponseT> {
58 ResultRetryAlgorithm<ResponseT> resultAlgorithm, TimedRetryAlgorithm timedAlgorithm) { in StreamingRetryAlgorithm()
29 import com.google.api.gax.retrying.ResultRetryAlgorithm;114 private static final ResultRetryAlgorithm<Operation> OPERATION_HANDLER =115 new ResultRetryAlgorithm<Operation>() {