@@ -125,18 +125,18 @@ void testShutdown() throws IOException {
125125 verify (mockSender ).close ();
126126 assertThat (logs .getEvents ()).isEmpty ();
127127 assertThat (
128- exporter
129- .export (Collections .singletonList (spanBuilder ().build ()))
130- .join (10 , TimeUnit .SECONDS )
131- .isSuccess ())
128+ exporter
129+ .export (Collections .singletonList (spanBuilder ().build ()))
130+ .join (10 , TimeUnit .SECONDS )
131+ .isSuccess ())
132132 .isFalse ();
133133 assertThat (exporter .shutdown ().isSuccess ()).isTrue ();
134134 logs .assertContains ("Calling shutdown() multiple times." );
135135 }
136136
137137 @ Test
138138 @ SuppressWarnings ({"PreferJavaTimeOverload" , "deprecation" })
139- // we have to use the deprecated setEncoder overload to test it
139+ // we have to use the deprecated setEncoder overload to test it
140140 void invalidConfig () {
141141 assertThatThrownBy (() -> ZipkinSpanExporter .builder ().setReadTimeout (-1 , TimeUnit .MILLISECONDS ))
142142 .isInstanceOf (IllegalArgumentException .class )
@@ -163,7 +163,7 @@ void invalidConfig() {
163163 .hasMessage ("sender" );
164164
165165 assertThatThrownBy (
166- () -> ZipkinSpanExporter .builder ().setEncoder ((zipkin2 .codec .BytesEncoder <Span >) null ))
166+ () -> ZipkinSpanExporter .builder ().setEncoder ((zipkin2 .codec .BytesEncoder <Span >) null ))
167167 .isInstanceOf (NullPointerException .class )
168168 .hasMessage ("encoder" );
169169
@@ -253,25 +253,25 @@ void stringRepresentation() {
253253
254254 @ Test
255255 void testSuppressInstrumentation () {
256- AtomicBoolean suppressInstrumentation = new AtomicBoolean (
257- InstrumentationUtil .shouldSuppressInstrumentation (Context .current ()));
256+ AtomicBoolean suppressInstrumentation =
257+ new AtomicBoolean ( InstrumentationUtil .shouldSuppressInstrumentation (Context .current ()));
258258
259259 assertFalse (suppressInstrumentation .get ());
260260
261- InstrumentationUtil .suppressInstrumentation (() ->
262- {
263- try (BytesMessageSender sender = OkHttpSender .newBuilder ().endpoint ("https://localhost" )
264- .encoding (Encoding .PROTO3 )
265- .build ()) {
261+ InstrumentationUtil .suppressInstrumentation (
262+ () -> {
263+ try (BytesMessageSender sender =
264+ OkHttpSender .newBuilder ()
265+ .endpoint ("https://localhost" )
266+ .encoding (Encoding .PROTO3 )
267+ .build ()) {
266268 sender .send (Collections .singletonList (new byte [0 ]));
267269 } catch (IOException e ) {
268- //it always goes here
270+ // it always goes here
269271 suppressInstrumentation .set (
270272 InstrumentationUtil .shouldSuppressInstrumentation (Context .current ()));
271273 }
272- }
273- );
274+ });
274275 assertTrue (suppressInstrumentation .get ());
275276 }
276-
277277}
0 commit comments