From e97dc7d03ce57bd4e05fda8e6918db5917e9057d Mon Sep 17 00:00:00 2001 From: Mirro Mutth Date: Mon, 1 Apr 2024 10:28:53 +0900 Subject: [PATCH] Polishing InitFlow --- .../java/io/asyncer/r2dbc/mysql/InitFlow.java | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/InitFlow.java b/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/InitFlow.java index 32dcc1c8a..753ff7f8a 100644 --- a/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/InitFlow.java +++ b/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/InitFlow.java @@ -126,12 +126,19 @@ final class InitFlow { * @param password the password of the {@code user}. * @param compressionAlgorithms the list of compression algorithms. * @param zstdCompressionLevel the zstd compression level. - * @return a {@link Flux} that indicates the initialization is done, or an error if the initialization failed. + * @return a {@link Mono} that indicates the initialization is done, or an error if the initialization failed. */ - static Flux initHandshake(Client client, SslMode sslMode, String database, String user, + static Mono initHandshake(Client client, SslMode sslMode, String database, String user, @Nullable CharSequence password, Set compressionAlgorithms, int zstdCompressionLevel) { - return client.exchange(new HandshakeExchangeable(client, sslMode, database, user, password, - compressionAlgorithms, zstdCompressionLevel)); + return client.exchange(new HandshakeExchangeable( + client, + sslMode, + database, + user, + password, + compressionAlgorithms, + zstdCompressionLevel + )).then(); } /**