scratch

scratch.kts

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.flow.collect

println("scratch start")
runBlocking{
	println("test start")
	val receivedValues = mutableListOf<Int>()
	val sharedFlow = MutableSharedFlow<Int>()
	val job = GlobalScope.launch{
		println("before collect")
		sharedFlow.collect {
			println("collect: $it")
			synchronized(receivedValues) {
				receivedValues.add(it)
				if(receivedValues.size >= 2) cancel()
			}
		}
	}
	delay(100L)
	println("before emits")
	sharedFlow.emit(1)
	sharedFlow.emit(2)
	println("wait end..")
	job.join()
	println("receivedValues=$receivedValues")
}