From a90789891070d4b7a247be0459cede380f667b44 Mon Sep 17 00:00:00 2001
From: Stephane Maldini <smaldini@pivotal.io>
Date: Fri, 22 Jan 2016 23:11:31 +0000
Subject: [PATCH] fix signature

---
 .../server/reactive/boot/ReactorHttpServer.java     | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

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 757e6e6810..2538a4588d 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,7 +16,8 @@
 
 package org.springframework.http.server.reactive.boot;
 
-import reactor.core.util.ReactiveState;
+import reactor.core.trait.Completable;
+import reactor.core.trait.Connectable;
 import reactor.io.buffer.Buffer;
 import reactor.io.net.ReactiveNet;
 
@@ -28,7 +29,7 @@ import org.springframework.util.Assert;
  * @author Stephane Maldini
  */
 public class ReactorHttpServer extends HttpServerSupport
-		implements InitializingBean, HttpServer, ReactiveState.FeedbackLoop, ReactiveState.ActiveUpstream {
+		implements InitializingBean, HttpServer, Connectable, Completable {
 
 	private ReactorHttpHandlerAdapter reactorHandler;
 
@@ -52,12 +53,12 @@ public class ReactorHttpServer extends HttpServerSupport
 	}
 
 	@Override
-	public Object delegateInput() {
+	public Object connectedInput() {
 		return reactorServer;
 	}
 
 	@Override
-	public Object delegateOutput() {
+	public Object connectedOutput() {
 		return reactorServer;
 	}
 
@@ -92,4 +93,8 @@ public class ReactorHttpServer extends HttpServerSupport
 		}
 	}
 
+	@Override
+	public Object upstream() {
+		return null;
+	}
 }