sync

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;

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