From ff6b639cf9ea00a4a96f85175e0bc11f1d40c7ea Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Mon, 11 Apr 2016 16:04:01 +0100 Subject: [PATCH] sync with dispatchOn change in reactor-core --- .../http/server/reactive/AsyncIntegrationTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()))); }