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 c1bfe69d16..c335796d0c 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
@@ -16,6 +16,7 @@
 
 package org.springframework.http.server.reactive.boot;
 
+import reactor.core.support.ReactiveState;
 import reactor.io.buffer.Buffer;
 import reactor.io.net.ReactiveNet;
 
@@ -27,7 +28,7 @@ import org.springframework.http.server.reactive.ReactorHttpHandlerAdapter;
  * @author Stephane Maldini
  */
 public class ReactorHttpServer extends HttpServerSupport
-		implements InitializingBean, HttpServer {
+		implements InitializingBean, HttpServer, ReactiveState.FeedbackLoop, ReactiveState.ActiveUpstream {
 
 	private ReactorHttpHandlerAdapter reactorHandler;
 
@@ -50,6 +51,26 @@ public class ReactorHttpServer extends HttpServerSupport
 				ReactiveNet.httpServer());
 	}
 
+	@Override
+	public Object delegateInput() {
+		return reactorServer;
+	}
+
+	@Override
+	public Object delegateOutput() {
+		return reactorServer;
+	}
+
+	@Override
+	public boolean isStarted() {
+		return running;
+	}
+
+	@Override
+	public boolean isTerminated() {
+		return !running;
+	}
+
 	@Override
 	public void start() {
 		if (!this.running) {