Browse Source

Pass URI to Reactor Netty HttpClient

See gh-29954
pull/29975/head
James Yuzawa 3 years ago committed by rstoyanchev
parent
commit
dd3dc2d0d0
  1. 2
      spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java
  2. 2
      spring-web/src/main/java/org/springframework/http/client/reactive/ReactorNetty2ClientHttpConnector.java

2
spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java

@ -107,7 +107,7 @@ public class ReactorClientHttpConnector implements ClientHttpConnector { @@ -107,7 +107,7 @@ public class ReactorClientHttpConnector implements ClientHttpConnector {
return this.httpClient
.request(io.netty.handler.codec.http.HttpMethod.valueOf(method.name()))
.uri(uri.toString())
.uri(uri)
.send((request, outbound) -> requestCallback.apply(adaptRequest(method, uri, request, outbound)))
.responseConnection((response, connection) -> {
responseRef.set(new ReactorClientHttpResponse(response, connection));

2
spring-web/src/main/java/org/springframework/http/client/reactive/ReactorNetty2ClientHttpConnector.java

@ -108,7 +108,7 @@ public class ReactorNetty2ClientHttpConnector implements ClientHttpConnector { @@ -108,7 +108,7 @@ public class ReactorNetty2ClientHttpConnector implements ClientHttpConnector {
return this.httpClient
.request(io.netty5.handler.codec.http.HttpMethod.valueOf(method.name()))
.uri(uri.toString())
.uri(uri)
.send((request, outbound) -> requestCallback.apply(adaptRequest(method, uri, request, outbound)))
.responseConnection((response, connection) -> {
responseRef.set(new ReactorNetty2ClientHttpResponse(response, connection));

Loading…
Cancel
Save