Skip to content

Commit d05059a

Browse files
committed
Bumping versions
1 parent 18dc5a4 commit d05059a

File tree

1 file changed

+9
-10
lines changed
  • tests/brave/spring-cloud-sleuth-instrumentation-webflux-tests/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web

1 file changed

+9
-10
lines changed

tests/brave/spring-cloud-sleuth-instrumentation-webflux-tests/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web/TraceWebFluxTests.java

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,6 @@ private void thenNoTraceWasLeaked(AssertingWebFilter assertingWebFilter) {
174174
then(assertingWebFilter.getSpans()).isEmpty();
175175
}
176176

177-
178177
private void thenSomeTraceWasAvailableInDoAfter(InnerAssertingWebFilter assertingWebFilter) {
179178
then(assertingWebFilter.getSpans()).hasSize(1);
180179
assertingWebFilter.getSpans().clear();
@@ -266,7 +265,6 @@ AssertingWebFilter traceIdInResponseLastFilter(Tracer tracer) {
266265
return new AssertingWebFilter(tracer);
267266
}
268267

269-
270268
@Bean
271269
@Order(Ordered.LOWEST_PRECEDENCE)
272270
WebFilter innerFilterDoAfterTerminate(Tracer tracer) {
@@ -276,7 +274,8 @@ WebFilter innerFilterDoAfterTerminate(Tracer tracer) {
276274
}
277275

278276
static class InnerAssertingWebFilter implements WebFilter {
279-
final Queue<Span> spans = new ConcurrentLinkedQueue<>();
277+
278+
final Queue<Span> spans = new ConcurrentLinkedQueue<>();
280279

281280
private final Tracer tracer;
282281

@@ -286,18 +285,18 @@ static class InnerAssertingWebFilter implements WebFilter {
286285

287286
@Override
288287
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain webFilterChain) {
289-
return webFilterChain.filter(exchange)
290-
.doAfterTerminate(() -> {
291-
Span currentSpan = tracer.currentSpan();
292-
if (currentSpan != null) {
293-
spans.add(currentSpan);
294-
}
295-
});
288+
return webFilterChain.filter(exchange).doAfterTerminate(() -> {
289+
Span currentSpan = tracer.currentSpan();
290+
if (currentSpan != null) {
291+
spans.add(currentSpan);
292+
}
293+
});
296294
}
297295

298296
Queue<Span> getSpans() {
299297
return spans;
300298
}
299+
301300
}
302301

303302
static class AssertingWebFilter implements WebFilter {

0 commit comments

Comments
 (0)