Cold Flow Turbine

Cold Flow Turbine.kt

    /**
     * Unit Testing Cold Flows with Turbine
     */

    @Test
    fun `cold flow - take multiple - Turbine`() {
        runBlocking {
            flow {
                emit("test")
                emit("test")
            }.test {
                assertThat(expectItem()).isEqualTo("test")
                assertThat(expectItem()).isEqualTo("test")
                expectComplete()
            }
        }
    }

    @Test
    fun `cold flow - take multiple - alternative - Turbine`() {
        runBlocking {
            flow {
                emit("test")
                emit("test")
            }.test {
                val actual = cancelAndConsumeRemainingEvents()
                assertThat(actual).containsExactly(
                    Event.Item("test"),
                    Event.Item("test"),
                    Event.Complete
                )
            }
        }
    }

    @Test
    fun `cold flow - take too little - Turbine - catches our implementation change!`() {
        runBlocking {
            flow {
                emit("test")
                emit("test")
                emit("test") // Added an extra emission, simulating an implementation change
            }.test {
                assertThat(expectItem()).isEqualTo("test")
                assertThat(expectItem()).isEqualTo("test")
                expectComplete()
            }
        }
    }

    @Test
    fun `cold flow - take too much - Turbine -- catches our implementation change!`() {
        runBlocking {
            flow {
                emit("test")
                // Deleted the second emission, simulating an implementation change
            }.test {
                assertThat(expectItem()).isEqualTo("test")
                assertThat(expectItem()).isEqualTo("test")
                expectComplete()
            }
        }
    }