github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[jOOQ/jOOQ#9335] The Unit vs T specialisation isn't necessary in kotlin

Browse Source
This commit is contained in:
Lukas Eder 2022-06-01 09:58:52 +02:00
parent 7ef55aff8c
commit 91438c5122
1 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
jOOQ-kotlin-coroutines/src/main/kotlin/org/jooq/kotlin/coroutines/CoroutineExtensions.kt
View File

@ -1,25 +1,15 @@
package org.jooq.kotlin.coroutines
import kotlinx.coroutines.reactive.awaitFirst
import kotlinx.coroutines.reactive.awaitFirstOrNull
import kotlinx.coroutines.reactor.mono
import org.jooq.*
import org.jooq.impl.DSL.*
import java.util.stream.Collector
import org.jooq.Configuration
import org.jooq.DSLContext
// ----------------------------------------------------------------------------
// Extensions to bridge between the reactive-streams and the coroutine world
// ----------------------------------------------------------------------------
suspend fun DSLContext.transactionCoroutine(transactional: suspend (Configuration) -> Unit) {
transactionPublisher { c ->
mono {
transactional.invoke(c)
}
}.awaitFirst()
}
suspend fun <T> DSLContext.transactionCoroutineResult(transactional: suspend (Configuration) -> T): T {
suspend fun <T> DSLContext.transactionCoroutine(transactional: suspend (Configuration) -> T): T {
return transactionPublisher { c ->
mono {
transactional.invoke(c)