如何正确测试带延迟的无限协程循环

问：

我有一个无限运行的协程函数，每 8 秒进行一次 API 调用。我正在尝试测试它，但感觉有些不对劲。代码如下：

class RefreshStocksUseCaseImpl(
    private val dispatcherProvider: DispatcherProvider,
    private val stocksRepository: StocksRepository
) : RefreshStocksUseCase {

    override suspend fun invoke() {
        withContext(dispatcherProvider.io) {
            try {
                while (true) {
                    stocksRepository.refreshStocks()
                    delay(THRESHOLD)
                }
            } catch (t: Throwable) {
                // We could make some extra handling here.
                throw t
            }
        }
    }

    companion object {

        private const val THRESHOLD = 8_000L // 8 seconds
    }
}

我的测试如下所示：

@ExperimentalCoroutinesApi
class RefreshStocksUseCaseImplTest {

    private lateinit var useCase: RefreshStocksUseCase

    private val dispatcherProvider = TestDispatcherProvider()

    @MockK
    private lateinit var stocksRepository: StocksRepository

    @Before
    fun setup() {
        MockKAnnotations.init(this, relaxUnitFun = false)
        useCase = RefreshStocksUseCaseImpl(dispatcherProvider, stocksRepository)
    }

    @Test
    fun `refreshStocks is called again after threshold`() = dispatcherProvider.io.runBlockingTest {
        coEvery { stocksRepository.refreshStocks() } just runs

        val job = launch {
            useCase()
        }
        advanceTimeBy(8_000)

        job.cancel()
        coVerify(exactly = 2) { stocksRepository.refreshStocks() }
    }
}

即使它过去了，我也觉得我做错了什么。我觉得应该在这里扮演一些角色......欢迎任何改进。pauseDispatcher