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

[jOOQ/jOOQ#13752] Returning null from transactionCoroutine throws NoSuchElementException

Browse Source
This commit is contained in:
Lukas Eder 2022-07-04 12:15:33 +02:00
parent 0450b0c00f
commit f0a7b51b30
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,6 +1,6 @@
package org.jooq.kotlin.coroutines
import kotlinx.coroutines.reactive.awaitFirst
import kotlinx.coroutines.reactive.awaitFirstOrNull
import kotlinx.coroutines.reactor.mono
import org.jooq.Configuration
import org.jooq.DSLContext
@ -10,9 +10,10 @@ import org.jooq.DSLContext
// ----------------------------------------------------------------------------
suspend fun <T> DSLContext.transactionCoroutine(transactional: suspend (Configuration) -> T): T {
@Suppress("UNCHECKED_CAST")
return transactionPublisher { c ->
mono {
transactional.invoke(c)
}
}.awaitFirst()
}.awaitFirstOrNull() as T
}