Skip to content

Instantly share code, notes, and snippets.

@mreram
Created July 25, 2020 21:28
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