Package-level declarations

Functions

Link copied to clipboard
suspend fun <T> TransactionalOperator.executeAndAwait(f: suspend (ReactiveTransaction) -> T): T

Coroutines variant of TransactionalOperator.execute with a suspending lambda parameter.

Link copied to clipboard
fun <T : Any> Flow<T>.transactional(operator: TransactionalOperator, context: CoroutineContext = EmptyCoroutineContext): Flow<T>

Coroutines variant of TransactionalOperator.transactional as a Flow extension.