xref: /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/example-flow-13.kt (revision 7a7160fed73afa6648ef8aa100d4a336fe921d9a) 

<lambda>null1 // This file was automatically generated from flow.md by Knit tool. Do not edit.
2 package kotlinx.coroutines.guide.exampleFlow13
3 
4 import kotlinx.coroutines.*
5 import kotlinx.coroutines.flow.*
6 
7 fun log(msg: String) = println("[${Thread.currentThread().name}] $msg")
8 
9 fun simple(): Flow<Int> = flow {
10     log("Started simple flow")
11     for (i in 1..3) {
12         emit(i)
13     }
14 }
15 
<lambda>null16 fun main() = runBlocking<Unit> {
17     simple().collect { value -> log("Collected $value") }
18 }
19