From d05059a106c0a353c451a3862102ebb8ed2db8dd Mon Sep 17 00:00:00 2001 From: buildmaster Date: Wed, 15 Mar 2023 15:59:37 +0000 Subject: [PATCH] Bumping versions --- .../instrument/web/TraceWebFluxTests.java | 19 +++++++++---------- 1 file changed, 9 insertions(+), 10 deletions(-) diff --git a/tests/brave/spring-cloud-sleuth-instrumentation-webflux-tests/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web/TraceWebFluxTests.java b/tests/brave/spring-cloud-sleuth-instrumentation-webflux-tests/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web/TraceWebFluxTests.java index 3448f715b..3f55d22eb 100644 --- a/tests/brave/spring-cloud-sleuth-instrumentation-webflux-tests/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web/TraceWebFluxTests.java +++ b/tests/brave/spring-cloud-sleuth-instrumentation-webflux-tests/src/test/java/org/springframework/cloud/sleuth/brave/instrument/web/TraceWebFluxTests.java @@ -174,7 +174,6 @@ public class TraceWebFluxTests { then(assertingWebFilter.getSpans()).isEmpty(); } - private void thenSomeTraceWasAvailableInDoAfter(InnerAssertingWebFilter assertingWebFilter) { then(assertingWebFilter.getSpans()).hasSize(1); assertingWebFilter.getSpans().clear(); @@ -266,7 +265,6 @@ public class TraceWebFluxTests { return new AssertingWebFilter(tracer); } - @Bean @Order(Ordered.LOWEST_PRECEDENCE) WebFilter innerFilterDoAfterTerminate(Tracer tracer) { @@ -276,7 +274,8 @@ public class TraceWebFluxTests { } static class InnerAssertingWebFilter implements WebFilter { - final Queue spans = new ConcurrentLinkedQueue<>(); + + final Queue spans = new ConcurrentLinkedQueue<>(); private final Tracer tracer; @@ -286,18 +285,18 @@ public class TraceWebFluxTests { @Override public Mono filter(ServerWebExchange exchange, WebFilterChain webFilterChain) { - return webFilterChain.filter(exchange) - .doAfterTerminate(() -> { - Span currentSpan = tracer.currentSpan(); - if (currentSpan != null) { - spans.add(currentSpan); - } - }); + return webFilterChain.filter(exchange).doAfterTerminate(() -> { + Span currentSpan = tracer.currentSpan(); + if (currentSpan != null) { + spans.add(currentSpan); + } + }); } Queue getSpans() { return spans; } + } static class AssertingWebFilter implements WebFilter {