Skip to content

Commit 4a8b015

Browse files
committed
Merge branch '1040-http-client' into 3.x
2 parents c148115 + c5630a7 commit 4a8b015

File tree

1 file changed

+12
-3
lines changed

1 file changed

+12
-3
lines changed

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/_DefaultConnectionContext.java

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@
4949
import java.time.Duration;
5050
import java.util.List;
5151
import java.util.Optional;
52+
import java.util.function.UnaryOperator;
5253

5354
import static com.fasterxml.jackson.annotation.JsonInclude.Include.NON_NULL;
5455
import static io.netty.channel.ChannelOption.CONNECT_TIMEOUT_MILLIS;
@@ -102,9 +103,12 @@ public Integer getConnectionPoolSize() {
102103
@Override
103104
@Value.Default
104105
public HttpClient getHttpClient() {
105-
return createHttpClient().compress(true)
106-
.tcpConfiguration(this::configureTcpClient)
107-
.secure(this::configureSsl);
106+
HttpClient client = createHttpClient().compress(true)
107+
.secure(this::configureSsl)
108+
.tcpConfiguration(this::configureTcpClient);
109+
110+
return getAdditionalHttpClientConfiguration().map(configuration -> configuration.apply(client))
111+
.orElse(client);
108112
}
109113

110114
@Override
@@ -152,6 +156,11 @@ public Mono<Void> trust(String host, int port) {
152156
.orElse(Mono.empty());
153157
}
154158

159+
/**
160+
* Additional configuration for the underlying HttpClient
161+
*/
162+
abstract Optional<UnaryOperator<HttpClient>> getAdditionalHttpClientConfiguration();
163+
155164
/**
156165
* The hostname of the API root. Typically something like {@code api.run.pivotal.io}.
157166
*/

0 commit comments

Comments
 (0)