SpringCloud/spring-cloud-sleuth
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Bumping versions

Browse Source
This commit is contained in:
buildmaster
2023-03-15 15:59:37 +00:00
parent 18dc5a4141
commit d05059a106
1 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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<Span> spans = new ConcurrentLinkedQueue<>();
final Queue<Span> spans = new ConcurrentLinkedQueue<>();
private final Tracer tracer;
@@ -286,18 +285,18 @@ public class TraceWebFluxTests {
@Override
public Mono<Void> 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<Span> getSpans() {
return spans;
}
}
static class AssertingWebFilter implements WebFilter {