diff --git a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java
index 5b4b4da4bea..83781e29f9b 100644
--- a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java
+++ b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java
@@ -44,7 +44,7 @@ public abstract class AbstractHttpHandlerIntegrationTests {
 		return new Object[][] {
 				{new JettyHttpServer()},
 				{new RxNettyHttpServer()},
-//				{new ReactorHttpServer()},
+				{new ReactorHttpServer()},
 				{new TomcatHttpServer()},
 				{new UndertowHttpServer()}
 		};
diff --git a/spring-web-reactive/src/test/java/org/springframework/web/reactive/handler/SimpleUrlHandlerMappingIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/web/reactive/handler/SimpleUrlHandlerMappingIntegrationTests.java
index 82690ca99d2..5b7a76143ae 100644
--- a/spring-web-reactive/src/test/java/org/springframework/web/reactive/handler/SimpleUrlHandlerMappingIntegrationTests.java
+++ b/spring-web-reactive/src/test/java/org/springframework/web/reactive/handler/SimpleUrlHandlerMappingIntegrationTests.java
@@ -24,7 +24,7 @@ import java.util.Map;
 import org.junit.Test;
 import reactor.Mono;
 import reactor.io.buffer.Buffer;
-import reactor.rx.Streams;
+import reactor.rx.Stream;
 
 import org.springframework.context.support.StaticApplicationContext;
 import org.springframework.http.HttpStatus;
@@ -136,7 +136,7 @@ public class SimpleUrlHandlerMappingIntegrationTests extends AbstractHttpHandler
 
 		@Override
 		public Mono<Void> handle(ServerHttpRequest request, ServerHttpResponse response) {
-			return response.setBody(Streams.just(Buffer.wrap("foo").byteBuffer()));
+			return response.setBody(Stream.just(Buffer.wrap("foo").byteBuffer()));
 		}
 	}
 
@@ -144,7 +144,7 @@ public class SimpleUrlHandlerMappingIntegrationTests extends AbstractHttpHandler
 
 		@Override
 		public Mono<Void> handle(ServerHttpRequest request, ServerHttpResponse response) {
-			return response.setBody(Streams.just(Buffer.wrap("bar").byteBuffer()));
+			return response.setBody(Stream.just(Buffer.wrap("bar").byteBuffer()));
 		}
 	}