diff --git a/build.gradle b/build.gradle index 9900d6378e6..84c51575e0a 100644 --- a/build.gradle +++ b/build.gradle @@ -171,7 +171,7 @@ configure(allprojects) { project -> repositories { maven { url "https://repo.spring.io/libs-release" } maven { url "https://repo.spring.io/milestone" } - maven { url "https://repo.spring.io/snapshot" } + maven { url "https://repo.spring.io/snapshot" } // reactor-netty 0.6 snapshots } dependencies { diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorHttpHandlerAdapter.java b/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorHttpHandlerAdapter.java index df695436538..aa9f55328e3 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorHttpHandlerAdapter.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorHttpHandlerAdapter.java @@ -48,11 +48,9 @@ public class ReactorHttpHandlerAdapter extends HttpHandlerAdapterSupport @Override public Mono apply(HttpServerRequest request, HttpServerResponse response) { - NettyDataBufferFactory bufferFactory = new NettyDataBufferFactory(request.channel() - .alloc()); + NettyDataBufferFactory bufferFactory = new NettyDataBufferFactory(request.channel().alloc()); ReactorServerHttpRequest req = new ReactorServerHttpRequest(request, bufferFactory); - ReactorServerHttpResponse resp = new ReactorServerHttpResponse(response, - bufferFactory); + ReactorServerHttpResponse resp = new ReactorServerHttpResponse(response, bufferFactory); return getHttpHandler().handle(req, resp) .otherwise(ex -> { 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 410738e9642..5903996c818 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 @@ -67,10 +67,9 @@ public class ReactorHttpServer extends HttpServerSupport implements HttpServer, @Override public void start() { - //Should be made thread-safe (compareAndSet..) + // TODO: should be made thread-safe (compareAndSet..) if (this.running == null) { - this.running = this.reactorServer.newHandler(reactorHandler) - .block(); + this.running = this.reactorServer.newHandler(reactorHandler).block(); } }