Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
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()
}
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment