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();
 	}