StateFlowTest.kt

import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.FlowPreview
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.MutableStateFlow
import kotlinx.coroutines.flow.collect
import kotlinx.coroutines.launch
import kotlinx.coroutines.test.runBlockingTest
import org.junit.Test


class StateFlowTest2 {

    @ExperimentalCoroutinesApi
    companion object {
        private val stateFlow = MutableStateFlow("initial value")

    }

    @FlowPreview
    @ExperimentalCoroutinesApi
    @Test
    fun `send and receive a bullshit`() {
        runBlockingTest {
            val collectionJob = launch {
                stateFlow.collect {
                    println(it)
                }
            }

            launch {
                delay(2000)
                stateFlow.value = "heyyy"
                collectionJob.cancel()
            }

        }
    }
}