使用 Kotlin Flow 测试 Android 房间

Question

我正在尝试测试 Room DAO 公开函数 return Flows。以下测试不会通过，我正在努力寻找原因：

    @Test
    fun `observeHomeCoursesFeatured() does not return courses that are no longer featured`() = runBlocking {
        val outputList: MutableList<List<HomeCourse>> = mutableListOf()
        launch { subject.observeHomeCoursesFeatured().collect { outputList.add(it) } }

        subject.saveHomeCoursesFeatured(listOf(getHomeCourseFeatured1(), getHomeCourseFeatured2()))
        subject.saveHomeCoursesFeatured(listOf(getHomeCourseFeatured1()))

        assertEquals(2, outputList.size)
        assertEquals(listOf(getHomeCourseFeatured1(), getHomeCourseFeatured2()), outputList[0])
        assertEquals(listOf(getHomeCourseFeatured1()), outputList[1])
    }

它在 assertEquals(2, outputList.size) 失败，说 outputList 是空的。

此测试通过：

    @Test
    fun `observeHomeCoursesFeatured() does not return courses that are no longer featured`() = runBlocking {
        subject.saveHomeCoursesFeatured(listOf(getHomeCourseFeatured1(), getHomeCourseFeatured2()))
        assertEquals(listOf(getHomeCourseFeatured1(), getHomeCourseFeatured2()), subject.observeHomeCoursesFeatured().first())

        subject.saveHomeCoursesFeatured(listOf(getHomeCourseFeatured1()))
        assertEquals(listOf(getHomeCourseFeatured1()), subject.observeHomeCoursesFeatured().first())
    }

第二次测试通过，表明我的 DAO 工作正常，这更多是测试线程与 Room 用于触发 Flow 更改的线程之间的线程和并发问题。

我已经在测试中添加了 @get:Rule val archRule = InstantTaskExecutorRule()。我还用这个构建了我的测试数据库：

db = Room.inMemoryDatabaseBuilder(ctx, CoreDatabase::class.java)
            .setTransactionExecutor(Executors.newSingleThreadExecutor())
            .allowMainThreadQueries()
            .build()

我错过了什么？

Answer 1

launch 是异步的，所以你有竞争条件。

@Test
fun `observeHomeCoursesFeatured() does not return courses that are no longer featured`() = runBlocking {
    val job = async { subject.observeHomeCoursesFeatured().take(2).toList() }

    subject.saveHomeCoursesFeatured(listOf(getHomeCourseFeatured1(), getHomeCourseFeatured2()))
    subject.saveHomeCoursesFeatured(listOf(getHomeCourseFeatured1()))

    val outputList = job.await()

    assertEquals(2, outputList.size)
    assertEquals(listOf(getHomeCourseFeatured1(), getHomeCourseFeatured2()), outputList[0])
    assertEquals(listOf(getHomeCourseFeatured1()), outputList[1])
}

使用 Kotlin Flow 测试 Android 房间

Testing Android Room with Kotlin Flow

android

kotlin

android-room

kotlin-coroutines

kotlin-flow