diff --git a/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java b/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java index ffae45d92d..8294964fc1 100644 --- a/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java +++ b/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java @@ -65,7 +65,6 @@ public class ReactorClientHttpConnector implements ClientHttpConnector { uri.toString(), httpClientRequest -> requestCallback .apply(new ReactorClientHttpRequest(method, uri, httpClientRequest))) - .otherwise(HttpClientException.class, exc -> Mono.just(exc.getResponse())) .map(ReactorClientHttpResponse::new); } diff --git a/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpRequest.java b/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpRequest.java index 216fade96d..7bd23f864c 100644 --- a/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpRequest.java +++ b/spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpRequest.java @@ -53,7 +53,7 @@ public class ReactorClientHttpRequest extends AbstractClientHttpRequest { HttpClientRequest httpRequest) { this.httpMethod = httpMethod; this.uri = uri; - this.httpRequest = httpRequest; + this.httpRequest = httpRequest.failOnClientError(false); this.bufferFactory = new NettyDataBufferFactory(httpRequest.alloc()); } diff --git a/spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java b/spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java index 8535ebddfc..1b705ed5f5 100644 --- a/spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java +++ b/spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java @@ -47,7 +47,7 @@ public abstract class AbstractHttpHandlerIntegrationTests { return new Object[][] { {new JettyHttpServer()}, {new RxNettyHttpServer()}, - //{new ReactorHttpServer()}, + {new ReactorHttpServer()}, {new TomcatHttpServer(base.getAbsolutePath())}, {new UndertowHttpServer()} };