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

Added a workaround for fixes gh-881

Browse Source
This commit is contained in:
Marcin Grzejszczak
2018-03-04 12:46:38 +01:00
parent 347c63ea82
commit 86295d89a1
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ReactorSleuth.java
View File

@@ -24,6 +24,7 @@ import org.reactivestreams.Publisher;
import org.springframework.beans.factory.BeanFactory;
import reactor.core.Fuseable;
import reactor.core.Scannable;
import reactor.core.publisher.ConnectableFlux;
import reactor.core.publisher.Operators;
import reactor.util.context.Context;
@@ -102,7 +103,7 @@ public abstract class ReactorSleuth {
}
private static final Predicate<Scannable> POINTCUT_FILTER =
s -> !(s instanceof Fuseable.ScalarCallable) && s.isScanAvailable();
s -> !(s instanceof ConnectableFlux) && !(s instanceof Fuseable.ScalarCallable) && s.isScanAvailable();
private ReactorSleuth() {
}