diff --git a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java
index fd8bfe8094..6e99d57c92 100644
--- a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java
+++ b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java
@@ -67,7 +67,7 @@ public class AsyncIntegrationTests extends AbstractHttpHandlerIntegrationTests {
 			return response.setBody(Flux.just("h", "e", "l", "l", "o")
 			                            .useTimer(Timer.global())
 			                            .delay(Duration.ofMillis(100))
-			                            .dispatchOn(asyncGroup)
+			                            .publishOn(asyncGroup)
 			                            .collect(allocator::allocateBuffer,
 			                               (buffer, str) -> buffer.write(str.getBytes())));
 		}