From 88233bf7187a13c2a2a5ebd050f5461843586898 Mon Sep 17 00:00:00 2001 From: Marcin Grzejszczak Date: Sat, 5 Aug 2017 22:59:38 +0200 Subject: [PATCH] Fixing Reactor --- .../cloud/sleuth/instrument/reactor/SpanSubscriberTests.java | 2 +- .../cloud/sleuth/instrument/web/TraceWebFluxTests.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/reactor/SpanSubscriberTests.java b/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/reactor/SpanSubscriberTests.java index a27fbdb68..252703142 100644 --- a/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/reactor/SpanSubscriberTests.java +++ b/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/reactor/SpanSubscriberTests.java @@ -180,7 +180,7 @@ public class SpanSubscriberTests { @AfterClass public static void cleanup() { - Hooks.resetOnNewSubscriber(); + Hooks.resetOnEachOperator(); Schedulers.resetFactory(); } diff --git a/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/web/TraceWebFluxTests.java b/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/web/TraceWebFluxTests.java index 296a4db51..135738df0 100644 --- a/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/web/TraceWebFluxTests.java +++ b/spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/web/TraceWebFluxTests.java @@ -34,7 +34,7 @@ public class TraceWebFluxTests { @BeforeClass public static void setup() { - Hooks.resetOnNewSubscriber(); + Hooks.resetOnEachOperator(); Schedulers.resetFactory(); }