From 13cb04f514a708e50ad6b4a935a049258f115cc1 Mon Sep 17 00:00:00 2001 From: ikonic89 Date: Tue, 3 Sep 2024 14:58:38 +0200 Subject: [PATCH] Deffer connection creation --- .../r2dbc/connection/ClickHouseConnectionFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 index 5abf420a5..5486f3a96 100644 --- 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 create() { - return Mono.just(new ClickHouseConnection(nodes)); + return Mono.defer(() -> Mono.just(new ClickHouseConnection(nodes))); } @Override