Unit Test Hot Flow Take

Unit Test Hot Flow Take.kt

    /**
     * Unit Testing Hot Flows the Android recommended way
     */

    @Ignore
    @Test
    fun `hot flow - hangs`() {
        runBlocking {
            val actual = MutableStateFlow("test").single()
            assertThat(actual).isEqualTo("test")
        }
    }

    @Test
    fun `hot flow - This job has not completed yet`() {
        rule.testDispatcher.runBlockingTest {
            val actual = MutableStateFlow("test").single()
            assertThat(actual).isEqualTo("test")
        }
    }

    @Test
    fun `hot flow first - Success!`() {
        runBlocking {
            val actual = MutableStateFlow("test").first() // first() cancels the Flow
            assertThat(actual).isEqualTo("test")
        }
    }