2020
2121import com .google .api .gax .httpjson .ApiMethodDescriptor ;
2222import com .google .api .gax .httpjson .ForwardingHttpJsonClientCall ;
23+ import com .google .api .gax .httpjson .ForwardingHttpJsonClientCallListener ;
2324import com .google .api .gax .httpjson .HttpJsonCallOptions ;
2425import com .google .api .gax .httpjson .HttpJsonChannel ;
2526import com .google .api .gax .httpjson .HttpJsonClientCall ;
@@ -76,8 +77,7 @@ public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> interceptCall(
7677 public void start (ClientCall .Listener <ResponseT > responseListener , Metadata headers ) {
7778 requestHeaders = headers ;
7879 ClientCall .Listener <ResponseT > forwardingResponseListener =
79- new ForwardingClientCallListener .SimpleForwardingClientCallListener <ResponseT >(
80- responseListener ) {
80+ new ForwardingClientCallListener .SimpleForwardingClientCallListener <ResponseT >(responseListener ) {
8181 @ Override
8282 public void onClose (io .grpc .Status status , Metadata trailers ) {
8383 responseTrailers = trailers ;
@@ -90,8 +90,7 @@ public void onClose(io.grpc.Status status, Metadata trailers) {
9090 }
9191 }
9292
93- private static class HttpJsonResponseCapturingClientInterceptor
94- implements HttpJsonClientInterceptor {
93+ private static class HttpJsonResponseCapturingClientInterceptor implements HttpJsonClientInterceptor {
9594 private HttpJsonMetadata requestHeaders ;
9695
9796 @ Override
@@ -204,8 +203,7 @@ void testTracePropagation_grpc() {
204203 String expectedTraceId = attemptSpan .getSpanContext ().getTraceId ();
205204 String expectedSpanId = attemptSpan .getSpanContext ().getSpanId ();
206205 String expectedTraceFlags = attemptSpan .getSpanContext ().getTraceFlags ().asHex ();
207- String expectedTraceparent =
208- "00-" + expectedTraceId + "-" + expectedSpanId + "-" + expectedTraceFlags ;
206+ String expectedTraceparent = "00-" + expectedTraceId + "-" + expectedSpanId + "-" + expectedTraceFlags ;
209207
210208 String headerValue = grpcInterceptor .requestHeaders .get (TRACEPARENT_GRPC_HEADER_KEY );
211209 assertThat (headerValue ).isNotNull ();
@@ -230,8 +228,7 @@ void testTracePropagation_httpjson() {
230228 String expectedTraceId = attemptSpan .getSpanContext ().getTraceId ();
231229 String expectedSpanId = attemptSpan .getSpanContext ().getSpanId ();
232230 String expectedTraceFlags = attemptSpan .getSpanContext ().getTraceFlags ().asHex ();
233- String expectedTraceparent =
234- "00-" + expectedTraceId + "-" + expectedSpanId + "-" + expectedTraceFlags ;
231+ String expectedTraceparent = "00-" + expectedTraceId + "-" + expectedSpanId + "-" + expectedTraceFlags ;
235232
236233 assertThat (httpJsonInterceptor .requestHeaders ).isNotNull ();
237234 Map <String , Object > headers = httpJsonInterceptor .requestHeaders .getHeaders ();
@@ -240,12 +237,12 @@ void testTracePropagation_httpjson() {
240237
241238 Object headerVal = headers .get (expectedHttpHeaderKey );
242239 if (headerVal instanceof List ) {
243- @ SuppressWarnings ("unchecked" )
244- List <String > traceparentHeaders = (List <String >) headerVal ;
245- assertThat (traceparentHeaders ).hasSize (1 );
246- assertThat (traceparentHeaders .get (0 )).isEqualTo (expectedTraceparent );
240+ @ SuppressWarnings ("unchecked" )
241+ List <String > traceparentHeaders = (List <String >) headerVal ;
242+ assertThat (traceparentHeaders ).hasSize (1 );
243+ assertThat (traceparentHeaders .get (0 )).isEqualTo (expectedTraceparent );
247244 } else {
248- assertThat (String .valueOf (headerVal )).isEqualTo (expectedTraceparent );
245+ assertThat (String .valueOf (headerVal )).isEqualTo (expectedTraceparent );
249246 }
250247 }
251248}
0 commit comments