From 52292cafaeb9c9c5740510c747098c9560aed608 Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Thu, 4 Feb 2016 03:08:26 +0000 Subject: [PATCH] sync reactor-core scheduler --- .../http/server/reactive/AsyncIntegrationTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 8ac52a6114..8463c12949 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 @@ -25,7 +25,7 @@ import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; import reactor.core.publisher.Mono; -import reactor.core.publisher.ProcessorGroup; +import reactor.core.publisher.SchedulerGroup; import reactor.core.timer.Timer; import reactor.rx.Stream; @@ -50,7 +50,7 @@ import static org.junit.Assert.assertThat; @RunWith(Parameterized.class) public class AsyncIntegrationTests { - private final ProcessorGroup asyncGroup = ProcessorGroup.async(); + private final SchedulerGroup asyncGroup = SchedulerGroup.async(); private final DataBufferAllocator allocator = new DefaultDataBufferAllocator();