alex.tavella
05/28/2021, 12:37 AM[Turbine]
Any idea why this test fails?
@Test
fun testBatchEmission() = runBlocking {
flow {
val result = mutableListOf<Int>()
for (i in 1..56) {
result.add(i)
if (i % 10 == 0) emit(result)
}
emit(result)
}.test {
assertEquals(10, expectItem().size)
assertEquals(20, expectItem().size)
assertEquals(30, expectItem().size)
assertEquals(40, expectItem().size)
assertEquals(50, expectItem().size)
assertEquals(56, expectItem().size)
expectComplete()
}
}