Skip to content

Commit d4c3cc0

Browse files
committed
Fix consistency of extensions
Signed-off-by: George Papadopoulos <[email protected]>
1 parent 6bdc7db commit d4c3cc0

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

spring-data-r2dbc/src/main/kotlin/org/springframework/data/r2dbc/core/ReactiveSelectOperationExtensions.kt

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,10 @@ package org.springframework.data.r2dbc.core
1717

1818
import kotlinx.coroutines.flow.Flow
1919
import kotlinx.coroutines.reactive.asFlow
20+
import kotlinx.coroutines.reactive.awaitFirst
2021
import kotlinx.coroutines.reactive.awaitFirstOrNull
2122
import kotlinx.coroutines.reactive.awaitSingle
23+
import kotlinx.coroutines.reactor.awaitSingleOrNull
2224

2325
/**
2426
* Extensions for [ReactiveSelectOperation].
@@ -49,13 +51,13 @@ suspend inline fun <reified T : Any> ReactiveSelectOperation.TerminatingSelect<T
4951
* Nullable Coroutines variant of [ReactiveSelectOperation.TerminatingSelect.one].
5052
*/
5153
suspend inline fun <reified T : Any> ReactiveSelectOperation.TerminatingSelect<T>.awaitOneOrNull(): T? =
52-
one().awaitFirstOrNull()
54+
one().awaitSingleOrNull()
5355

5456
/**
5557
* Non-nullable Coroutines variant of [ReactiveSelectOperation.TerminatingSelect.first].
5658
*/
5759
suspend inline fun <reified T : Any> ReactiveSelectOperation.TerminatingSelect<T>.awaitFirst(): T =
58-
first().awaitSingle()
60+
first().awaitFirst()
5961

6062
/**
6163
* Nullable Coroutines variant of [ReactiveSelectOperation.TerminatingSelect.first].

0 commit comments

Comments
 (0)