From 44f4930e296a390105a2de19a89e6b4d4e1ecbec Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Thu, 28 Jan 2016 20:36:29 +0000 Subject: [PATCH] sync --- .../web/server/adapter/DefaultServerWebExchange.java | 1 - .../http/server/reactive/AsyncIntegrationTests.java | 3 +-- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java b/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java index 99e1f641dde..a7d7ed550c0 100644 --- a/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java +++ b/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java @@ -20,7 +20,6 @@ import java.util.concurrent.ConcurrentHashMap; import reactor.core.publisher.FluxProcessor; import reactor.core.publisher.Mono; -import reactor.core.publisher.Processors; import org.springframework.http.server.reactive.ServerHttpRequest; import org.springframework.http.server.reactive.ServerHttpResponse; 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 99c8c0523e4..8ac52a6114a 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 @@ -26,7 +26,6 @@ import org.junit.runner.RunWith; import org.junit.runners.Parameterized; import reactor.core.publisher.Mono; import reactor.core.publisher.ProcessorGroup; -import reactor.core.publisher.Processors; import reactor.core.timer.Timer; import reactor.rx.Stream; @@ -51,7 +50,7 @@ import static org.junit.Assert.assertThat; @RunWith(Parameterized.class) public class AsyncIntegrationTests { - private final ProcessorGroup asyncGroup = Processors.asyncGroup(); + private final ProcessorGroup asyncGroup = ProcessorGroup.async(); private final DataBufferAllocator allocator = new DefaultDataBufferAllocator();