diff options
Diffstat (limited to 'kotlinx-coroutines-core/common/src/flow/terminal/Collect.kt')
| -rw-r--r-- | kotlinx-coroutines-core/common/src/flow/terminal/Collect.kt | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/kotlinx-coroutines-core/common/src/flow/terminal/Collect.kt b/kotlinx-coroutines-core/common/src/flow/terminal/Collect.kt index 42c66296..d26839f9 100644 --- a/kotlinx-coroutines-core/common/src/flow/terminal/Collect.kt +++ b/kotlinx-coroutines-core/common/src/flow/terminal/Collect.kt @@ -127,5 +127,7 @@ public suspend fun <T> Flow<T>.collectLatest(action: suspend (value: T) -> Unit) * Collects all the values from the given [flow] and emits them to the collector. * It is a shorthand for `flow.collect { value -> emit(value) }`. */ -@BuilderInference -public suspend inline fun <T> FlowCollector<T>.emitAll(flow: Flow<T>): Unit = flow.collect(this) +public suspend fun <T> FlowCollector<T>.emitAll(flow: Flow<T>) { + ensureActive() + flow.collect(this) +} |