diff --git a/spring-data-r2dbc/src/main/kotlin/org/springframework/data/r2dbc/core/ReactiveSelectOperationExtensions.kt b/spring-data-r2dbc/src/main/kotlin/org/springframework/data/r2dbc/core/ReactiveSelectOperationExtensions.kt index 3b97be7b0f8..6c1150a4442 100644 --- a/spring-data-r2dbc/src/main/kotlin/org/springframework/data/r2dbc/core/ReactiveSelectOperationExtensions.kt +++ b/spring-data-r2dbc/src/main/kotlin/org/springframework/data/r2dbc/core/ReactiveSelectOperationExtensions.kt @@ -17,8 +17,10 @@ package org.springframework.data.r2dbc.core import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.reactive.asFlow +import kotlinx.coroutines.reactive.awaitFirst import kotlinx.coroutines.reactive.awaitFirstOrNull import kotlinx.coroutines.reactive.awaitSingle +import kotlinx.coroutines.reactor.awaitSingleOrNull /** * Extensions for [ReactiveSelectOperation]. @@ -49,13 +51,13 @@ suspend inline fun ReactiveSelectOperation.TerminatingSelect ReactiveSelectOperation.TerminatingSelect.awaitOneOrNull(): T? = - one().awaitFirstOrNull() + one().awaitSingleOrNull() /** * Non-nullable Coroutines variant of [ReactiveSelectOperation.TerminatingSelect.first]. */ suspend inline fun ReactiveSelectOperation.TerminatingSelect.awaitFirst(): T = - first().awaitSingle() + first().awaitFirst() /** * Nullable Coroutines variant of [ReactiveSelectOperation.TerminatingSelect.first].