From 86295d89a1c18a55cc9b78bce2019cad62408fac Mon Sep 17 00:00:00 2001 From: Marcin Grzejszczak Date: Sun, 4 Mar 2018 12:46:38 +0100 Subject: [PATCH] Added a workaround for fixes gh-881 --- .../cloud/sleuth/instrument/reactor/ReactorSleuth.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ReactorSleuth.java b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ReactorSleuth.java index 47ba879fd..3eb2510cd 100644 --- a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ReactorSleuth.java +++ b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ReactorSleuth.java @@ -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 POINTCUT_FILTER = - s -> !(s instanceof Fuseable.ScalarCallable) && s.isScanAvailable(); + s -> !(s instanceof ConnectableFlux) && !(s instanceof Fuseable.ScalarCallable) && s.isScanAvailable(); private ReactorSleuth() { }