如何UnitTest networkBoundResource的kotlin-flow版本？

@Test
fun testNetworkBoundResource() = runBlockingTest {
    // 创建一个Mock的网络请求结果
    val networkData = listOf("Data 1", "Data 2", "Data 3")
    val networkFlow = flow { emit(networkData) }

    // 创建一个Mock的本地缓存数据
    val cachedData = listOf("Cached Data 1", "Cached Data 2", "Cached Data 3")
    val cacheFlow = flow { emit(cachedData) }

    // 创建一个Mock的数据转换函数
    val transformFunction: suspend (List<String>) -> List<String> = { data -> data.map { "Transformed $it" } }

    // 创建一个Mock的数据存储函数
    val saveFunction: suspend (List<String>) -> Unit = { data -> /* 存储数据到本地 */ }

    // 创建一个Mock的判断是否需要从网络获取数据的函数
    val shouldFetchFunction: suspend (List<String>) -> Boolean = { data -> data.isEmpty() }

    // 创建一个Mock的判断是否需要将网络数据存储到本地的函数
    val shouldSaveFunction: suspend (List<String>) -> Boolean = { data -> true }

    // 创建一个Mock的错误处理函数
    val errorHandler: suspend (Throwable) -> Unit = { error -> /* 处理错误 */ }

    // 创建一个Mock的Loading状态
    val loadingState = flowOf(Resource.loading<List<String>>(null))

    // 创建一个Mock的Success状态
    val successState = flowOf(Resource.success(transformFunction(networkData)))

    // 创建一个Mock的Error状态
    val errorState = flowOf(Resource.error<List<String>>("Error", null))

    // 创建一个Mock的FlowCollector
    val collector = mockk<FlowCollector<Resource<List<String>>>>()

    // 创建一个网络绑定资源对象
    val networkBoundResource = NetworkBoundResource(
        fetchFromNetwork = { networkFlow },
        fetchFromCache = { cacheFlow },
        transform = transformFunction,
        saveToCache = saveFunction,
        shouldFetch = shouldFetchFunction,
        shouldSave = shouldSaveFunction,
        errorHandler = errorHandler
    )

    // 设置网络绑定资源的状态
    coEvery { collector.emit(any()) } just Runs

    // 测试网络绑定资源的流程
    networkBoundResource.collect(collector)

    // 验证网络绑定资源的状态是否正确
    coVerifySequence {
        collector.emit(loadingState)
        collector.emit(successState)
    }
}