diff --git a/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorHttpClientRequestFactory.java b/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorHttpClientRequestFactory.java index e759e3b85f..ce0cd81812 100644 --- a/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorHttpClientRequestFactory.java +++ b/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorHttpClientRequestFactory.java @@ -18,7 +18,6 @@ package org.springframework.http.client.reactive; import java.net.URI; -import reactor.io.netty.ReactiveNet; import reactor.io.netty.http.HttpClient; import org.springframework.core.io.buffer.DataBufferAllocator; @@ -43,7 +42,7 @@ public class ReactorHttpClientRequestFactory implements ClientHttpRequestFactory } public ReactorHttpClientRequestFactory(DataBufferAllocator allocator) { - this(allocator, ReactiveNet.httpClient()); + this(allocator, reactor.io.netty.http.HttpClient.create()); } protected ReactorHttpClientRequestFactory(DataBufferAllocator allocator, HttpClient httpClient) { diff --git a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/boot/ReactorHttpServer.java b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/boot/ReactorHttpServer.java index 5cbd81bfea..4887a6741d 100644 --- a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/boot/ReactorHttpServer.java +++ b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/boot/ReactorHttpServer.java @@ -19,7 +19,6 @@ package org.springframework.http.server.reactive.boot; import reactor.core.flow.Loopback; import reactor.core.state.Completable; import reactor.io.buffer.Buffer; -import reactor.io.netty.ReactiveNet; import org.springframework.core.io.buffer.DataBufferAllocator; import org.springframework.core.io.buffer.DefaultDataBufferAllocator; @@ -50,8 +49,8 @@ public class ReactorHttpServer extends HttpServerSupport Assert.notNull(getHttpHandler()); this.reactorHandler = new ReactorHttpHandlerAdapter(getHttpHandler(), allocator); - this.reactorServer = (getPort() != -1 ? ReactiveNet.httpServer(getPort()) : - ReactiveNet.httpServer()); + this.reactorServer = (getPort() != -1 ? reactor.io.netty.http.HttpServer.create(getPort()) : + reactor.io.netty.http.HttpServer.create()); } @Override