Merge pull request #1810 from ikonic89/1447-deffer-connection-creation

chernser · web-flow · commit f3a4ab8f33d5 · 2024-09-05T22:36:04.000-07:00
R2DBC - Defer connection creation
diff --git a/clickhouse-r2dbc/src/main/java/com/clickhouse/r2dbc/connection/ClickHouseConnectionFactory.java b/clickhouse-r2dbc/src/main/java/com/clickhouse/r2dbc/connection/ClickHouseConnectionFactory.java
@@ -18,7 +18,7 @@ public class ClickHouseConnectionFactory implements ConnectionFactory {
 
     @Override
     public Mono<? extends Connection> create() {
-        return Mono.just(new ClickHouseConnection(nodes));
+        return Mono.defer(() -> Mono.just(new ClickHouseConnection(nodes)));
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ public class ClickHouseConnectionFactory implements ConnectionFactory {`
`18`	`18`
`19`	`19`	`@Override`
`20`	`20`	`public Mono<? extends Connection> create() {`
`21`		`- return Mono.just(new ClickHouseConnection(nodes));`
	`21`	`+ return Mono.defer(() -> Mono.just(new ClickHouseConnection(nodes)));`
`22`	`22`	`}`
`23`	`23`
`24`	`24`	`@Override`