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

Fix initialization issue in ReactorResourceFactory

Browse Source 
Follow-up on recent commit #d537a1c.

Issue: SPR-17243
This commit is contained in:
Rossen Stoyanchev
2018-09-06 15:13:45 -04:00
parent f55a6051df
commit 2163fa94a7
2 changed files with 141 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-web/src/main/java/org/springframework/http/client/reactive/ReactorResourceFactory.java
View File

@@ -46,9 +46,9 @@ public class ReactorResourceFactory implements InitializingBean, DisposableBean
private Consumer<HttpResources> globalResourcesConsumer;
private Supplier<ConnectionProvider> connectionProviderSupplier = () -> ConnectionProvider.elastic("http");
private Supplier<ConnectionProvider> connectionProviderSupplier = () -> ConnectionProvider.elastic("webflux");
private Supplier<LoopResources> loopResourcesSupplier = () -> LoopResources.create("reactor-http");
private Supplier<LoopResources> loopResourcesSupplier = () -> LoopResources.create("webflux-http");
@Nullable
@@ -166,6 +166,8 @@ public class ReactorResourceFactory implements InitializingBean, DisposableBean
if (this.globalResourcesConsumer != null) {
this.globalResourcesConsumer.accept(httpResources);
}
this.connectionProvider = httpResources;
this.loopResources = httpResources;
}
else {
if (this.loopResources == null) {