diff --git a/src/main/kotlin/org/springframework/data/r2dbc/function/DatabaseClientExtensions.kt b/src/main/kotlin/org/springframework/data/r2dbc/function/DatabaseClientExtensions.kt index 163805b..e134893 100644 --- a/src/main/kotlin/org/springframework/data/r2dbc/function/DatabaseClientExtensions.kt +++ b/src/main/kotlin/org/springframework/data/r2dbc/function/DatabaseClientExtensions.kt @@ -23,7 +23,7 @@ import kotlinx.coroutines.reactive.awaitFirstOrNull * @author Sebastien Deleuze */ suspend fun DatabaseClient.GenericExecuteSpec.await() { - then().awaitFirstOrNull() + then().awaitFirstOrNull() } /** @@ -32,8 +32,8 @@ suspend fun DatabaseClient.GenericExecuteSpec.await() { * * @author Sebastien Deleuze */ -inline fun DatabaseClient.GenericExecuteSpec.asType(): DatabaseClient.TypedExecuteSpec - = `as`(T::class.java) +inline fun DatabaseClient.GenericExecuteSpec.asType(): DatabaseClient.TypedExecuteSpec = + `as`(T::class.java) /** * Extension for [DatabaseClient.GenericSelectSpec.as] providing a @@ -41,8 +41,8 @@ inline fun DatabaseClient.GenericExecuteSpec.asType(): Databas * * @author Sebastien Deleuze */ -inline fun DatabaseClient.GenericSelectSpec.asType(): DatabaseClient.TypedSelectSpec - = `as`(T::class.java) +inline fun DatabaseClient.GenericSelectSpec.asType(): DatabaseClient.TypedSelectSpec = + `as`(T::class.java) /** * Coroutines variant of [DatabaseClient.TypedExecuteSpec.then]. @@ -50,7 +50,7 @@ inline fun DatabaseClient.GenericSelectSpec.asType(): Database * @author Sebastien Deleuze */ suspend fun DatabaseClient.TypedExecuteSpec.await() { - then().awaitFirstOrNull() + then().awaitFirstOrNull() } /** @@ -59,8 +59,8 @@ suspend fun DatabaseClient.TypedExecuteSpec.await() { * * @author Sebastien Deleuze */ -inline fun DatabaseClient.TypedExecuteSpec.asType(): DatabaseClient.TypedExecuteSpec - = `as`(T::class.java) +inline fun DatabaseClient.TypedExecuteSpec.asType(): DatabaseClient.TypedExecuteSpec = + `as`(T::class.java) /** * Coroutines variant of [DatabaseClient.InsertSpec.then]. @@ -68,7 +68,7 @@ inline fun DatabaseClient.TypedExecuteSpec.asType(): Databa * @author Sebastien Deleuze */ suspend fun DatabaseClient.InsertSpec.await() { - then().awaitFirstOrNull() + then().awaitFirstOrNull() } /** @@ -77,6 +77,6 @@ suspend fun DatabaseClient.InsertSpec.await() { * * @author Sebastien Deleuze */ -inline fun DatabaseClient.InsertIntoSpec.into(): DatabaseClient.TypedInsertSpec - = into(T::class.java) +inline fun DatabaseClient.InsertIntoSpec.into(): DatabaseClient.TypedInsertSpec = + into(T::class.java) diff --git a/src/main/kotlin/org/springframework/data/r2dbc/function/RowsFetchSpecExtensions.kt b/src/main/kotlin/org/springframework/data/r2dbc/function/RowsFetchSpecExtensions.kt index cb1a1d0..34a09ae 100644 --- a/src/main/kotlin/org/springframework/data/r2dbc/function/RowsFetchSpecExtensions.kt +++ b/src/main/kotlin/org/springframework/data/r2dbc/function/RowsFetchSpecExtensions.kt @@ -23,32 +23,32 @@ import kotlinx.coroutines.reactive.awaitSingle * * @author Sebastien Deleuze */ -suspend fun RowsFetchSpec.awaitOne(): T - = one().awaitSingle() +suspend fun RowsFetchSpec.awaitOne(): T = + one().awaitSingle() /** * Nullable Coroutines variant of [RowsFetchSpec.one]. * * @author Sebastien Deleuze */ -suspend fun RowsFetchSpec.awaitOneOrNull(): T? - = one().awaitFirstOrNull() +suspend fun RowsFetchSpec.awaitOneOrNull(): T? = + one().awaitFirstOrNull() /** * Non-nullable Coroutines variant of [RowsFetchSpec.first]. * * @author Sebastien Deleuze */ -suspend fun RowsFetchSpec.awaitFirst(): T - = first().awaitSingle() +suspend fun RowsFetchSpec.awaitFirst(): T = + first().awaitSingle() /** * Nullable Coroutines variant of [RowsFetchSpec.first]. * * @author Sebastien Deleuze */ -suspend fun RowsFetchSpec.awaitFirstOrNull(): T? - = first().awaitFirstOrNull() +suspend fun RowsFetchSpec.awaitFirstOrNull(): T? = + first().awaitFirstOrNull() // TODO Coroutines variant of [RowsFetchSpec.all], depends on [kotlinx.coroutines#254](https://github.com/Kotlin/kotlinx.coroutines/issues/254). // suspend fun RowsFetchSpec.awaitAll() = all()...