root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Use URI String if necessary in ReactorClientHttpConnector 

Closes gh-30053
This commit is contained in:
rstoyanchev 2023-03-01 11:47:49 +00:00
parent 3456fd054f
commit fe73c630da
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
spring-web/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpConnector.java
View File

@ -105,9 +105,12 @@ public class ReactorClientHttpConnector implements ClientHttpConnector {
AtomicReference<ReactorClientHttpResponse> responseRef = new AtomicReference<>(); AtomicReference<ReactorClientHttpResponse> responseRef = new AtomicReference<>();
return this.httpClient HttpClient.RequestSender requestSender = this.httpClient
.request(io.netty.handler.codec.http.HttpMethod.valueOf(method.name())) .request(io.netty.handler.codec.http.HttpMethod.valueOf(method.name()));
.uri(uri)
requestSender = (uri.isAbsolute() ? requestSender.uri(uri) : requestSender.uri(uri.toString()));
return requestSender
.send((request, outbound) -> requestCallback.apply(adaptRequest(method, uri, request, outbound))) .send((request, outbound) -> requestCallback.apply(adaptRequest(method, uri, request, outbound)))
.responseConnection((response, connection) -> { .responseConnection((response, connection) -> {
responseRef.set(new ReactorClientHttpResponse(response, connection)); responseRef.set(new ReactorClientHttpResponse(response, connection));

9
spring-web/src/main/java/org/springframework/http/client/reactive/ReactorNetty2ClientHttpConnector.java
View File

@ -106,9 +106,12 @@ public class ReactorNetty2ClientHttpConnector implements ClientHttpConnector {
AtomicReference<ReactorNetty2ClientHttpResponse> responseRef = new AtomicReference<>(); AtomicReference<ReactorNetty2ClientHttpResponse> responseRef = new AtomicReference<>();
return this.httpClient HttpClient.RequestSender requestSender = this.httpClient
.request(io.netty5.handler.codec.http.HttpMethod.valueOf(method.name())) .request(io.netty5.handler.codec.http.HttpMethod.valueOf(method.name()));
.uri(uri)
requestSender = (uri.isAbsolute() ? requestSender.uri(uri) : requestSender.uri(uri.toString()));
return requestSender
.send((request, outbound) -> requestCallback.apply(adaptRequest(method, uri, request, outbound))) .send((request, outbound) -> requestCallback.apply(adaptRequest(method, uri, request, outbound)))
.responseConnection((response, connection) -> { .responseConnection((response, connection) -> {
responseRef.set(new ReactorNetty2ClientHttpResponse(response, connection)); responseRef.set(new ReactorNetty2ClientHttpResponse(response, connection));