From fbb0c702c98920f38a7d96ceb254e5c8dbb2556e Mon Sep 17 00:00:00 2001
From: Stephane Maldini <smaldini@pivotal.io>
Date: Wed, 9 Dec 2015 01:58:26 +0000
Subject: [PATCH] minor reactor server impl to fulfill core introspection

---
 .../reactive/boot/ReactorHttpServer.java      | 23 ++++++++++++++++++-
 1 file changed, 22 insertions(+), 1 deletion(-)

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) {