diff --git a/spring-web/src/test/java/org/springframework/http/server/reactive/bootstrap/ReactorHttpServer.java b/spring-web/src/test/java/org/springframework/http/server/reactive/bootstrap/ReactorHttpServer.java index 30bde7a4b0c..4ef630fe62e 100644 --- a/spring-web/src/test/java/org/springframework/http/server/reactive/bootstrap/ReactorHttpServer.java +++ b/spring-web/src/test/java/org/springframework/http/server/reactive/bootstrap/ReactorHttpServer.java @@ -18,7 +18,6 @@ package org.springframework.http.server.reactive.bootstrap; import java.util.concurrent.atomic.AtomicReference; -import reactor.core.Loopback; import reactor.ipc.netty.NettyContext; import org.springframework.http.server.reactive.ReactorHttpHandlerAdapter; @@ -26,7 +25,7 @@ import org.springframework.http.server.reactive.ReactorHttpHandlerAdapter; /** * @author Stephane Maldini */ -public class ReactorHttpServer extends AbstractHttpServer implements Loopback { +public class ReactorHttpServer extends AbstractHttpServer { private ReactorHttpHandlerAdapter reactorHandler; @@ -45,16 +44,6 @@ public class ReactorHttpServer extends AbstractHttpServer implements Loopback { return new ReactorHttpHandlerAdapter(resolveHttpHandler()); } - @Override - public Object connectedInput() { - return this.reactorServer; - } - - @Override - public Object connectedOutput() { - return this.reactorServer; - } - @Override protected void startInternal() { NettyContext nettyContext = this.reactorServer.newHandler(this.reactorHandler).block();