Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing

Browse Source
This commit is contained in:
Juergen Hoeller
2020-09-15 09:56:53 +02:00
parent 801c8ed8ac
commit f4bdc0284e
4 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-web/src/main/java/org/springframework/http/client/reactive/HttpComponentsClientHttpConnector.java
View File

@@ -90,13 +90,15 @@ public class HttpComponentsClientHttpConnector implements ClientHttpConnector {
this.client.start();
}
/**
* Set the buffer factory to be used.
* Set the buffer factory to use.
*/
public void setBufferFactory(DataBufferFactory bufferFactory) {
this.dataBufferFactory = bufferFactory;
}
@Override
public Mono<ClientHttpResponse> connect(HttpMethod method, URI uri,
Function<? super ClientHttpRequest, Mono<Void>> requestCallback) {
@@ -143,8 +145,8 @@ public class HttpComponentsClientHttpConnector implements ClientHttpConnector {
@Override
public void completed(Message<HttpResponse, Publisher<ByteBuffer>> result) {
HttpComponentsClientHttpResponse response = new HttpComponentsClientHttpResponse(this.dataBufferFactory,
result, this.context);
HttpComponentsClientHttpResponse response =
new HttpComponentsClientHttpResponse(this.dataBufferFactory, result, this.context);
this.sink.success(response);
}

2
spring-web/src/main/java/org/springframework/http/client/reactive/HttpComponentsClientHttpRequest.java
View File

@@ -85,7 +85,7 @@ class HttpComponentsClientHttpRequest extends AbstractClientHttpRequest {
return this.httpRequest.getUri();
}
catch (URISyntaxException ex) {
throw new IllegalArgumentException("Invalid URI syntax.", ex);
throw new IllegalArgumentException("Invalid URI syntax: " + ex.getMessage());
}
}

4
spring-web/src/main/java/org/springframework/http/client/reactive/HttpComponentsClientHttpResponse.java
View File

@@ -56,8 +56,7 @@ class HttpComponentsClientHttpResponse implements ClientHttpResponse {
public HttpComponentsClientHttpResponse(DataBufferFactory dataBufferFactory,
Message<HttpResponse, Publisher<ByteBuffer>> message,
HttpClientContext context) {
Message<HttpResponse, Publisher<ByteBuffer>> message, HttpClientContext context) {
this.dataBufferFactory = dataBufferFactory;
this.message = message;
@@ -112,4 +111,5 @@ class HttpComponentsClientHttpResponse implements ClientHttpResponse {
public HttpHeaders getHeaders() {
return this.headers;
}
}

4
spring-web/src/main/java/org/springframework/http/client/reactive/JettyClientHttpConnector.java
View File

@@ -91,13 +91,15 @@ public class JettyClientHttpConnector implements ClientHttpConnector {
}
}
/**
* Set the buffer factory to be used.
* Set the buffer factory to use.
*/
public void setBufferFactory(DataBufferFactory bufferFactory) {
this.bufferFactory = bufferFactory;
}
@Override
public Mono<ClientHttpResponse> connect(HttpMethod method, URI uri,
Function<? super ClientHttpRequest, Mono<Void>> requestCallback) {