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

Restore use of tcpConfiguration method

Browse Source 
The method wasn't available at first but has been added since to allow
being compatible with both Reactor Netty 0.9 and 1.0.

See gh-25085
This commit is contained in:
Rossen Stoyanchev
2020-06-21 21:11:34 +01:00
parent d627f6049e
commit 96bbec7ab2
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -75,12 +75,13 @@ public class ReactorClientHttpConnector implements ClientHttpConnector {
this.httpClient = defaultInitializer.andThen(mapper).apply(initHttpClient(factory));
}
@SuppressWarnings("deprecation")
private static HttpClient initHttpClient(ReactorResourceFactory resourceFactory) {
ConnectionProvider provider = resourceFactory.getConnectionProvider();
LoopResources resources = resourceFactory.getLoopResources();
Assert.notNull(provider, "No ConnectionProvider: is ReactorResourceFactory not initialized yet?");
Assert.notNull(resources, "No LoopResources: is ReactorResourceFactory not initialized yet?");
return HttpClient.create(provider).runOn(resources);
return HttpClient.create(provider).tcpConfiguration(tcpClient -> tcpClient.runOn(resources));
}
/**