Sync reactor-netty client response update and uncomment in tests
This commit is contained in:
parent
97ea22cb4a
commit
241d5f7a3b
|
@ -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);
|
||||
}
|
||||
|
||||
|
|
|
@ -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());
|
||||
}
|
||||
|
||||
|
|
|
@ -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()}
|
||||
};
|
||||
|
|
Loading…
Reference in New Issue