We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3651276 commit 21bb6fbCopy full SHA for 21bb6fb
kotlinx-coroutines-core/common/src/flow/internal/FlowCoroutine.kt
@@ -48,8 +48,7 @@ internal suspend fun <R> flowScope(@BuilderInference block: suspend CoroutineSco
48
*/
49
internal fun <R> scopedFlow(@BuilderInference block: suspend CoroutineScope.(FlowCollector<R>) -> Unit): Flow<R> =
50
flow {
51
- val collector = this
52
- flowScope { block(collector) }
+ flowScope { block(this@flow) }
53
}
54
55
internal fun <T> CoroutineScope.flowProduce(
0 commit comments