Searched refs:pollingAlgorithm (Results 1 – 5 of 5) sorted by relevance
44 private final TimedRetryAlgorithm pollingAlgorithm; field in OperationCallSettings53 return pollingAlgorithm; in getPollingAlgorithm()66 TimedRetryAlgorithm pollingAlgorithm, in OperationCallSettings() argument70 this.pollingAlgorithm = checkNotNull(pollingAlgorithm); in OperationCallSettings()87 private TimedRetryAlgorithm pollingAlgorithm; field in OperationCallSettings.Builder95 this.pollingAlgorithm = settings.pollingAlgorithm; in Builder()102 TimedRetryAlgorithm pollingAlgorithm) { in setPollingAlgorithm() argument103 this.pollingAlgorithm = pollingAlgorithm; in setPollingAlgorithm()109 return pollingAlgorithm; in getPollingAlgorithm()146 initialCallSettings, pollingAlgorithm, responseTransformer, metadataTransformer); in build()
219 RetryAlgorithm<OperationSnapshot> pollingAlgorithm = in longRunningOperationImpl() local223 new ScheduledRetryingExecutor<>(pollingAlgorithm, clientContext.getExecutor()); in longRunningOperationImpl()
64 TimedRetryAlgorithm pollingAlgorithm = Mockito.mock(TimedRetryAlgorithm.class); in testBuilder() local68 builder.setPollingAlgorithm(pollingAlgorithm); in testBuilder()77 Truth.assertThat(settings.getPollingAlgorithm()).isSameInstanceAs(pollingAlgorithm); in testBuilder()93 TimedRetryAlgorithm pollingAlgorithm = Mockito.mock(TimedRetryAlgorithm.class); in testBuilderFromSettings() local97 builder.setPollingAlgorithm(pollingAlgorithm); in testBuilderFromSettings()107 Truth.assertThat(newBuilder.getPollingAlgorithm()).isSameInstanceAs(pollingAlgorithm); in testBuilderFromSettings()
115 private OperationTimedPollAlgorithm pollingAlgorithm; field in OperationCallableImplTest126 pollingAlgorithm = OperationTimedPollAlgorithm.create(FAST_RECHECKING_SETTINGS, clock); in setUp()138 .setPollingAlgorithm(pollingAlgorithm) in setUp()477 pollingAlgorithm = in testFutureCallPollRPCTimeout()493 callSettings = callSettings.toBuilder().setPollingAlgorithm(pollingAlgorithm).build(); in testFutureCallPollRPCTimeout()586 pollingAlgorithm = in testFutureCallPollDoneOnMany()593 callSettings = callSettings.toBuilder().setPollingAlgorithm(pollingAlgorithm).build(); in testFutureCallPollDoneOnMany()696 pollingAlgorithm = in testFutureCallPollCancelOnLongTimeoutExceeded()700 callSettings = callSettings.toBuilder().setPollingAlgorithm(pollingAlgorithm).build(); in testFutureCallPollCancelOnLongTimeoutExceeded()
96 private OperationTimedPollAlgorithm pollingAlgorithm; field in GrpcLongRunningTest108 pollingAlgorithm = OperationTimedPollAlgorithm.create(FAST_RETRY_SETTINGS, clock); in setUp()133 .setPollingAlgorithm(pollingAlgorithm) in setUp()