reformat

Author: diegomarquezp

gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/SettingsTest.java

@@ -378,7 +378,9 @@ public void testWatchDogCheckInterval_backportMethodsBehaveCorrectly() {
         };
     testDurationMethod(
         123l,
-        jt -> build.apply(() -> FakeStubSettings.newBuilder().setStreamWatchdogCheckIntervalDuration(jt)),
+        jt ->
+            build.apply(
+                () -> FakeStubSettings.newBuilder().setStreamWatchdogCheckIntervalDuration(jt)),
         tt -> build.apply(() -> FakeStubSettings.newBuilder().setStreamWatchdogCheckInterval(tt)),
         ss -> ss.getStreamWatchdogCheckIntervalDuration(),
         ss -> ss.getStreamWatchdogCheckInterval());

gax-java/gax/src/main/java/com/google/api/gax/retrying/BasicRetryingFuture.java

@@ -187,7 +187,8 @@ void handleAttempt(Throwable throwable, ResponseT response) {
                   "retriableException: " + throwable
                 });
           }
-          tracer.attemptFailedDuration(throwable, nextAttemptSettings.getRandomizedRetryDelayDuration());
+          tracer.attemptFailedDuration(
+              throwable, nextAttemptSettings.getRandomizedRetryDelayDuration());
           attemptSettings = nextAttemptSettings;
           setAttemptResult(throwable, response, true);
           // a new attempt will be (must be) scheduled by an external executor

gax-java/gax/src/main/java/com/google/api/gax/retrying/TimedAttemptSettings.java

@@ -107,7 +107,8 @@ public abstract static class Builder {
     public abstract Builder setGlobalSettings(RetrySettings value);
 
     /**
-     * Backport of {@link #setRetryDelayDuration(java.time.Duration)} using {@link org.threeten.bp.Duration}
+     * Backport of {@link #setRetryDelayDuration(java.time.Duration)} using {@link
+     * org.threeten.bp.Duration}
      */
     @ObsoleteApi("Use setRetryDelayDuration(java.time.Duration) instead")
     public abstract Builder setRetryDelay(org.threeten.bp.Duration value);
@@ -121,7 +122,8 @@ public final Builder setRetryDelayDuration(java.time.Duration value) {
     }
 
     /**
-     * Backport of {@link #setRpcTimeoutDuration(java.time.Duration)} using {@link org.threeten.bp.Duration}
+     * Backport of {@link #setRpcTimeoutDuration(java.time.Duration)} using {@link
+     * org.threeten.bp.Duration}
      */
     @ObsoleteApi("Use setRpcTimeoutDuration(java.time.Duration) instead")
     public abstract Builder setRpcTimeout(org.threeten.bp.Duration value);

gax-java/gax/src/main/java/com/google/api/gax/rpc/Callables.java

@@ -105,7 +105,8 @@ private static <ResponseT> ScheduledRetryingExecutor<ResponseT> getRetryingExecu
       settings =
           settings
               .toBuilder()
-              .setSimpleTimeoutNoRetriesDuration(settings.getRetrySettings().getTotalTimeoutDuration())
+              .setSimpleTimeoutNoRetriesDuration(
+                  settings.getRetrySettings().getTotalTimeoutDuration())
               .build();
     }
 
@@ -129,7 +130,8 @@ public static <RequestT, ResponseT> ServerStreamingCallable<RequestT, ResponseT>
       settings =
           settings
               .toBuilder()
-              .setSimpleTimeoutNoRetriesDuration(settings.getRetrySettings().getTotalTimeoutDuration())
+              .setSimpleTimeoutNoRetriesDuration(
+                  settings.getRetrySettings().getTotalTimeoutDuration())
               .build();
     }
 

gax-java/gax/src/main/java/com/google/api/gax/rpc/ClientContext.java

@@ -252,7 +252,8 @@ public static ClientContext create(StubSettings settings) throws IOException {
     if (watchdogProvider != null) {
       if (watchdogProvider.needsCheckInterval()) {
         watchdogProvider =
-            watchdogProvider.withCheckIntervalDuration(settings.getStreamWatchdogCheckIntervalDuration());
+            watchdogProvider.withCheckIntervalDuration(
+                settings.getStreamWatchdogCheckIntervalDuration());
       }
       if (watchdogProvider.needsClock()) {
         watchdogProvider = watchdogProvider.withClock(clock);

gax-java/gax/src/main/java/com/google/api/gax/rpc/ClientSettings.java

@@ -29,6 +29,8 @@
  */
 package com.google.api.gax.rpc;
 
+import static com.google.api.gax.util.TimeConversionUtils.toJavaTimeDuration;
+
 import com.google.api.core.ApiClock;
 import com.google.api.core.ApiFunction;
 import com.google.api.core.ObsoleteApi;
@@ -40,8 +42,6 @@
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 
-import static com.google.api.gax.util.TimeConversionUtils.toJavaTimeDuration;
-
 /**
  * A base settings class to configure a client class.
  *

gax-java/gax/src/main/java/com/google/api/gax/rpc/FixedWatchdogProvider.java

@@ -32,7 +32,6 @@
 import com.google.api.core.ApiClock;
 import com.google.api.core.InternalApi;
 import com.google.api.core.ObsoleteApi;
-
 import java.util.concurrent.ScheduledExecutorService;
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;

gax-java/gax/src/main/java/com/google/api/gax/rpc/InstantiatingWatchdogProvider.java

@@ -29,6 +29,8 @@
  */
 package com.google.api.gax.rpc;
 
+import static com.google.api.gax.util.TimeConversionUtils.toJavaTimeDuration;
+
 import com.google.api.core.ApiClock;
 import com.google.api.core.InternalApi;
 import com.google.api.core.ObsoleteApi;
@@ -37,8 +39,6 @@
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 
-import static com.google.api.gax.util.TimeConversionUtils.toJavaTimeDuration;
-
 /**
  * A watchdog provider which instantiates a new provider on every request.
  *
@@ -90,7 +90,7 @@ public WatchdogProvider withCheckInterval(@Nonnull org.threeten.bp.Duration chec
   @Override
   public WatchdogProvider withCheckIntervalDuration(@Nonnull java.time.Duration checkInterval) {
     return new InstantiatingWatchdogProvider(
-            clock, executor, Preconditions.checkNotNull(checkInterval));
+        clock, executor, Preconditions.checkNotNull(checkInterval));
   }
 
   @Override

gax-java/gax/src/main/java/com/google/api/gax/rpc/ServerStreamingCallSettings.java

@@ -317,7 +317,8 @@ public java.time.Duration getIdleTimeoutDuration() {
     }
 
     /**
-     * Overlad of {@link #setIdleTimeoutDuration(java.time.Duration)} using {@link org.threeten.bp.Duration}
+     * Overlad of {@link #setIdleTimeoutDuration(java.time.Duration)} using {@link
+     * org.threeten.bp.Duration}
      */
     @ObsoleteApi("Use setIdleTimeoutDuration(java.time.Duration) instead")
     public Builder<RequestT, ResponseT> setIdleTimeout(
@@ -329,7 +330,8 @@ public Builder<RequestT, ResponseT> setIdleTimeout(
      * Set how long to wait before considering the stream orphaned by the user and closing it.
      * {@link java.time.Duration#ZERO} disables the check for abandoned streams.
      */
-    public Builder<RequestT, ResponseT> setIdleTimeoutDuration(@Nonnull java.time.Duration idleTimeout) {
+    public Builder<RequestT, ResponseT> setIdleTimeoutDuration(
+        @Nonnull java.time.Duration idleTimeout) {
       this.idleTimeout = Preconditions.checkNotNull(idleTimeout);
       return this;
     }
@@ -360,7 +362,8 @@ public Builder<RequestT, ResponseT> setWaitTimeout(
      * Set the maximum amount of time to wait for the next message from the server. {@link
      * java.time.Duration#ZERO} disables the check for abandoned streams.
      */
-    public Builder<RequestT, ResponseT> setWaitTimeoutDuration(@Nonnull java.time.Duration waitTimeout) {
+    public Builder<RequestT, ResponseT> setWaitTimeoutDuration(
+        @Nonnull java.time.Duration waitTimeout) {
       this.waitTimeout = waitTimeout;
       return this;
     }

gax-java/gax/src/main/java/com/google/api/gax/rpc/WatchdogProvider.java

@@ -32,7 +32,6 @@
 import com.google.api.core.ApiClock;
 import com.google.api.core.InternalApi;
 import com.google.api.core.ObsoleteApi;
-
 import java.util.concurrent.ScheduledExecutorService;
 import javax.annotation.Nonnull;
 

gax-java/gax/src/test/java/com/google/api/gax/batching/BatcherImplTest.java

@@ -386,7 +386,10 @@ public void testWhenThresholdIsDisabled() throws Exception {
   @Test
   public void testWhenDelayThresholdExceeds() throws Exception {
     BatchingSettings settings =
-        batchingSettings.toBuilder().setDelayThresholdDuration(java.time.Duration.ofMillis(100)).build();
+        batchingSettings
+            .toBuilder()
+            .setDelayThresholdDuration(java.time.Duration.ofMillis(100))
+            .build();
     underTest = createDefaultBatcherImpl(settings, null);
     Future<Integer> result = underTest.add(6);
     assertThat(result.isDone()).isFalse();
@@ -417,7 +420,10 @@ public ApiFuture<List<Integer>> futureCall(
           }
         };
     BatchingSettings settings =
-        batchingSettings.toBuilder().setDelayThresholdDuration(java.time.Duration.ofMillis(50)).build();
+        batchingSettings
+            .toBuilder()
+            .setDelayThresholdDuration(java.time.Duration.ofMillis(50))
+            .build();
 
     try (final BatcherImpl<Integer, Integer, LabeledIntList, List<Integer>> batcherTest =
         new BatcherImpl<>(SQUARER_BATCHING_DESC_V2, callable, labeledIntList, settings, EXECUTOR)) {

gax-java/gax/src/test/java/com/google/api/gax/batching/ThresholdBatcherTest.java

@@ -196,7 +196,9 @@ public void testBatchingWithDelay() throws Exception {
     AccumulatingBatchReceiver<SimpleBatch> receiver =
         new AccumulatingBatchReceiver<>(ApiFutures.<Void>immediateFuture(null));
     ThresholdBatcher<SimpleBatch> batcher =
-        createSimpleBatcherBuidler(receiver).setMaxDelayDuration(java.time.Duration.ofMillis(100)).build();
+        createSimpleBatcherBuidler(receiver)
+            .setMaxDelayDuration(java.time.Duration.ofMillis(100))
+            .build();
 
     batcher.add(SimpleBatch.fromInteger(3));
     batcher.add(SimpleBatch.fromInteger(5));

gax-java/gax/src/test/java/com/google/api/gax/retrying/AbstractRetryingExecutorTest.java

@@ -143,7 +143,8 @@ public void testSuccessWithFailures() throws Exception {
     assertEquals(5, future.getAttemptSettings().getAttemptCount());
 
     verify(tracer, times(6)).attemptStarted(eq("request"), anyInt());
-    verify(tracer, times(5)).attemptFailedDuration(any(Throwable.class), any(java.time.Duration.class));
+    verify(tracer, times(5))
+        .attemptFailedDuration(any(Throwable.class), any(java.time.Duration.class));
     verify(tracer, times(1)).attemptSucceeded();
     verifyNoMoreInteractions(tracer);
   }
@@ -188,7 +189,8 @@ public void testMaxRetriesExceeded() throws Exception {
     assertEquals(5, future.getAttemptSettings().getAttemptCount());
 
     verify(tracer, times(6)).attemptStarted(eq("request"), anyInt());
-    verify(tracer, times(5)).attemptFailedDuration(any(Throwable.class), any(java.time.Duration.class));
+    verify(tracer, times(5))
+        .attemptFailedDuration(any(Throwable.class), any(java.time.Duration.class));
     verify(tracer, times(1)).attemptFailedRetriesExhausted(any(Throwable.class));
     verifyNoMoreInteractions(tracer);
   }
@@ -266,7 +268,8 @@ public void testCancelByRetryingAlgorithm() throws Exception {
 
     verify(tracer, times(5)).attemptStarted(eq("request"), anyInt());
     // Pre-apocalypse failures
-    verify(tracer, times(4)).attemptFailedDuration(any(Throwable.class), any(java.time.Duration.class));
+    verify(tracer, times(4))
+        .attemptFailedDuration(any(Throwable.class), any(java.time.Duration.class));
     // Apocalypse failure
     verify(tracer, times(1)).attemptFailedRetriesExhausted(any(CancellationException.class));
     verifyNoMoreInteractions(tracer);
@@ -286,7 +289,8 @@ public void testUnexpectedExceptionFromRetryAlgorithm() throws Exception {
 
     verify(tracer, times(5)).attemptStarted(eq("request"), anyInt());
     // Pre-apocalypse failures
-    verify(tracer, times(4)).attemptFailedDuration(any(Throwable.class), any(java.time.Duration.class));
+    verify(tracer, times(4))
+        .attemptFailedDuration(any(Throwable.class), any(java.time.Duration.class));
     // Apocalypse failure
     verify(tracer, times(1)).attemptPermanentFailure(any(RuntimeException.class));
     verifyNoMoreInteractions(tracer);

gax-java/gax/src/test/java/com/google/api/gax/rpc/AttemptCallableTest.java

@@ -88,7 +88,8 @@ public void testRpcTimeout() {
 
     // Make sure that the rpc timeout is set
     java.time.Duration timeout = java.time.Duration.ofSeconds(10);
-    currentAttemptSettings = currentAttemptSettings.toBuilder().setRpcTimeoutDuration(timeout).build();
+    currentAttemptSettings =
+        currentAttemptSettings.toBuilder().setRpcTimeoutDuration(timeout).build();
 
     callable.call();
 
@@ -109,7 +110,8 @@ public void testRpcTimeoutIsNotErased() {
         FakeCallContext.createDefault().withTimeoutDuration(callerTimeout);
 
     java.time.Duration timeout = java.time.Duration.ofMillis(5);
-    currentAttemptSettings = currentAttemptSettings.toBuilder().setRpcTimeoutDuration(timeout).build();
+    currentAttemptSettings =
+        currentAttemptSettings.toBuilder().setRpcTimeoutDuration(timeout).build();
 
     AttemptCallable<String, String> callable =
         new AttemptCallable<>(mockInnerCallable, "fake-request", callerCallContext);

gax-java/gax/src/test/java/com/google/api/gax/rpc/CallableTest.java

@@ -86,7 +86,9 @@ public void testNonRetriedCallable() throws Exception {
     RequestMutator requestMutator = (request -> modifiedRequest);
 
     UnaryCallSettings<Object, Object> callSettings =
-        UnaryCallSettings.newUnaryCallSettingsBuilder().setSimpleTimeoutNoRetriesDuration(timeout).build();
+        UnaryCallSettings.newUnaryCallSettingsBuilder()
+            .setSimpleTimeoutNoRetriesDuration(timeout)
+            .build();
     UnaryCallable<String, String> callable =
         Callables.retrying(innerCallable, callSettings, clientContext, requestMutator);
     String expectedResponse = "No, my refrigerator is not running!";

gax-java/gax/src/test/java/com/google/api/gax/rpc/CheckingAttemptCallableTest.java

@@ -88,7 +88,8 @@ public void testRpcTimeout() {
 
     // Make sure that the rpc timeout is set
     java.time.Duration timeout = java.time.Duration.ofSeconds(10);
-    currentAttemptSettings = currentAttemptSettings.toBuilder().setRpcTimeoutDuration(timeout).build();
+    currentAttemptSettings =
+        currentAttemptSettings.toBuilder().setRpcTimeoutDuration(timeout).build();
 
     callable.call();
 

gax-java/gax/src/test/java/com/google/api/gax/rpc/FixedWatchdogProviderTest.java

@@ -29,7 +29,6 @@
  */
 package com.google.api.gax.rpc;
 
-import static com.google.api.gax.util.TimeConversionTestUtils.testDurationMethod;
 import static com.google.common.truth.Truth.assertThat;
 import static org.junit.Assert.assertThrows;
 
@@ -101,9 +100,15 @@ public void testNoModifications() {
 
   @Test
   public void testWithCheckInterval_backportMethodsBehaveTheSame() {
-    assertThrows(UnsupportedOperationException.class, () -> FixedWatchdogProvider.create(null)
-            .withCheckIntervalDuration(java.time.Duration.ofMillis(123l)));
-    assertThrows(UnsupportedOperationException.class, () -> FixedWatchdogProvider.create(null)
-            .withCheckInterval(org.threeten.bp.Duration.ofMillis(123l)));
+    assertThrows(
+        UnsupportedOperationException.class,
+        () ->
+            FixedWatchdogProvider.create(null)
+                .withCheckIntervalDuration(java.time.Duration.ofMillis(123l)));
+    assertThrows(
+        UnsupportedOperationException.class,
+        () ->
+            FixedWatchdogProvider.create(null)
+                .withCheckInterval(org.threeten.bp.Duration.ofMillis(123l)));
   }
 }

gax-java/gax/src/test/java/com/google/api/gax/rpc/InstantiatingWatchdogProviderTest.java

@@ -71,7 +71,9 @@ public void happyPath() {
   @Test
   public void requiresExecutor() {
     WatchdogProvider provider =
-        InstantiatingWatchdogProvider.create().withCheckIntervalDuration(checkInterval).withClock(clock);
+        InstantiatingWatchdogProvider.create()
+            .withCheckIntervalDuration(checkInterval)
+            .withClock(clock);
 
     Throwable actualError = null;
     try {
@@ -114,15 +116,14 @@ public void requiresClock() {
 
   @Test
   public void testCheckInterval_backportMethodsBehaveCorrectly() {
-    final InstantiatingWatchdogProvider baseProvider = (InstantiatingWatchdogProvider) InstantiatingWatchdogProvider.create()
-                    .withClock(clock)
-                  .withExecutor(executor);
+    final InstantiatingWatchdogProvider baseProvider =
+        (InstantiatingWatchdogProvider)
+            InstantiatingWatchdogProvider.create().withClock(clock).withExecutor(executor);
     testDurationMethod(
-            123l,
-            jt -> baseProvider.withCheckIntervalDuration(jt),
-            tt -> baseProvider.withCheckInterval(tt),
-            wp -> wp.getWatchdog().getScheduleIntervalDuration(),
-            wp -> wp.getWatchdog().getScheduleInterval()
-    );
+        123l,
+        jt -> baseProvider.withCheckIntervalDuration(jt),
+        tt -> baseProvider.withCheckInterval(tt),
+        wp -> wp.getWatchdog().getScheduleIntervalDuration(),
+        wp -> wp.getWatchdog().getScheduleInterval());
   }
 }

gax-java/gax/src/test/java/com/google/api/gax/rpc/ServerStreamingAttemptCallableTest.java

@@ -474,7 +474,8 @@ private static class FakeRetryingFuture extends AbstractApiFuture<Void>
       this.attemptCallable = attemptCallable;
       attemptSettings =
           TimedAttemptSettings.newBuilder()
-              .setGlobalSettings(RetrySettings.newBuilder().setTotalTimeoutDuration(totalTimeout).build())
+              .setGlobalSettings(
+                  RetrySettings.newBuilder().setTotalTimeoutDuration(totalTimeout).build())
               .setFirstAttemptStartTimeNanos(0)
               .setAttemptCount(0)
               .setOverallAttemptCount(0)

gax-java/gax/src/test/java/com/google/api/gax/rpc/UnaryCallSettingsTest.java

@@ -153,7 +153,10 @@ public void testToString() {
   public void testWatchDogCheckInterval_backportMethodsBehaveCorrectly() {
     testDurationMethod(
         123l,
-        jt -> UnaryCallSettings.newUnaryCallSettingsBuilder().setSimpleTimeoutNoRetriesDuration(jt).build(),
+        jt ->
+            UnaryCallSettings.newUnaryCallSettingsBuilder()
+                .setSimpleTimeoutNoRetriesDuration(jt)
+                .build(),
         tt -> UnaryCallSettings.newUnaryCallSettingsBuilder().setSimpleTimeoutNoRetries(tt).build(),
         ucs -> ucs.getRetrySettings().getTotalTimeoutDuration(),
         ucs -> ucs.getRetrySettings().getTotalTimeout());

gax-java/gax/src/test/java/com/google/api/gax/tracing/MetricsTestUtils.java

@@ -36,11 +36,12 @@
 public class MetricsTestUtils {
   public static void reportFailedAttempt(ApiTracer tracer, Exception ex, Object delayValue) {
     try {
-      final String methodName = delayValue.getClass().getName().startsWith("java.time") ? "attemptFailedDuration" : "attemptFailed";
+      final String methodName =
+          delayValue.getClass().getName().startsWith("java.time")
+              ? "attemptFailedDuration"
+              : "attemptFailed";
       Method attemptFailed =
-          tracer
-              .getClass()
-              .getDeclaredMethod(methodName, Throwable.class, delayValue.getClass());
+          tracer.getClass().getDeclaredMethod(methodName, Throwable.class, delayValue.getClass());
       attemptFailed.invoke(tracer, ex, delayValue);
     } catch (Exception e) {
       fail();