how can i unit test flows? the following never completes

@Test
    fun listCanBeObserved() = runBlocking {
        dao.insert(thing)

        val data: List<Thing> = dao.observeAll().single()
        val expected = Thing()
        assertEquals(expected, data)
    }

but if I manually collect each emission I can see the assertion is hit successfully in debug mode

fun listCanBeObserved() = runBlocking {
        dao.insert(thing)

        val data: List<Thing> = dao.observeAll().collect {
            val expected = Thing()
            assertEquals(expected, data)
        }
    }

but then the test will never complete

Use

first()

that’s not the reason the test won’t complete. copy-paste error but

expected

is

listOf(thing)

It kinda does, but it confirms that the flow only emits one item.

i see. thanks for your help