@@ -711,13 +711,9 @@ public void testCallContextPropagatedInMutationBatcher()
711711 // Override the timeout
712712 GrpcCallContext clientCtx =
713713 GrpcCallContext .createDefault ()
714- .withTimeout (Duration .ofMinutes (10 ))
715- .withRetrySettings (
716- RetrySettings .newBuilder ()
717- .setTotalTimeout (Duration .ofMinutes (10 ))
718- .build ()
719-
720- );
714+ .withTimeout (Duration .ofMinutes (10 ))
715+ .withRetrySettings (
716+ RetrySettings .newBuilder ().setTotalTimeout (Duration .ofMinutes (10 )).build ());
721717
722718 // Send a batch
723719 try (Batcher <RowMutationEntry , Void > batcher =
@@ -747,14 +743,10 @@ public void testCallContextPropagatedInReadBatcher()
747743
748744 // Override the timeout
749745 GrpcCallContext clientCtx =
750- GrpcCallContext .createDefault ()
751- .withTimeout (Duration .ofMinutes (10 ))
752- .withRetrySettings (
753- RetrySettings .newBuilder ()
754- .setTotalTimeout (Duration .ofMinutes (10 ))
755- .build ()
756-
757- );
746+ GrpcCallContext .createDefault ()
747+ .withTimeout (Duration .ofMinutes (10 ))
748+ .withRetrySettings (
749+ RetrySettings .newBuilder ().setTotalTimeout (Duration .ofMinutes (10 )).build ());
758750
759751 // Send a batch
760752 try (Batcher <ByteString , Row > batcher =
@@ -989,7 +981,7 @@ private static class ContextInterceptor implements ServerInterceptor {
989981 final BlockingQueue <MethodContext > contexts = Queues .newLinkedBlockingDeque ();
990982
991983 static class MethodContext {
992- final MethodDescriptor <?,?> method ;
984+ final MethodDescriptor <?, ?> method ;
993985 final Context context ;
994986
995987 MethodContext (MethodDescriptor <?, ?> method , Context context ) {
0 commit comments