使用MockWebServer暂停功能测试

我正在测试使用 MockWebServer 的挂起函数返回结果的 api，但它不适用于 runBlockingTest、testCoroutineDispatcher、testCorounieScope，除非launch使用builder，为什么？

abstract class AbstractPostApiTest {

    internal lateinit var mockWebServer: MockWebServer

    private val responseAsString by lazy {
        getResourceAsText(RESPONSE_JSON_PATH)
    }

    @BeforeEach
    open fun setUp() {
        mockWebServer = MockWebServer()
        println("AbstractPostApiTest setUp() $mockWebServer")
    }


    @AfterEach
    open fun tearDown() {
        mockWebServer.shutdown()
    }

    companion object {
        const val RESPONSE_JSON_PATH = "posts.json"
    }


    @Throws(IOException::class)
    fun enqueueResponse(
        code: Int = 200,
        headers: Map<String, String>? = null
    ): MockResponse {

        // Define mock response
        val mockResponse = MockResponse()
        // Set response code
        mockResponse.setResponseCode(code)

        // Set headers
        headers?.let {
            for ((key, value) in it) {
                mockResponse.addHeader(key, value)
            }
        }

        // Set body
        mockWebServer.enqueue(
            mockResponse.setBody(responseAsString)
        )

        return mockResponse
    }


}


class PostApiTest : AbstractPostApiTest() {

    private lateinit var postApi: PostApiCoroutines

    private val testCoroutineDispatcher = TestCoroutineDispatcher()

    private val testCoroutineScope = TestCoroutineScope(testCoroutineDispatcher)

    @BeforeEach
    override fun setUp() {
        super.setUp()

        val okHttpClient = OkHttpClient
            .Builder()
            .build()

        postApi = Retrofit.Builder()
            .baseUrl(mockWebServer.url("/"))
            .addConverterFactory(GsonConverterFactory.create())
            .client(okHttpClient)
            .build()
            .create(PostApiCoroutines::class.java)


        Dispatchers.setMain(testCoroutineDispatcher)

    }

    @AfterEach
    override fun tearDown() {
        super.tearDown()

        Dispatchers.resetMain()
        try {
            testCoroutineScope.cleanupTestCoroutines()
        } catch (exception: Exception) {
            exception.printStackTrace()
        }
    }

    @Test
    fun `Given we have a valid request, should be done to correct url`() =
        testCoroutineScope.runBlockingTest {

            // GIVEN
            enqueueResponse(200, RESPONSE_JSON_PATH)

            // WHEN
              postApi.getPostsResponse()

            advanceUntilIdle()

            val request = mockWebServer.takeRequest()

            // THEN
            Truth.assertThat(request.path).isEqualTo("/posts")

        }
}

结果错误：java.lang.IllegalStateException: This job has not completed yet

如果出现以下情况，则该测试不起作用launch使用构建器，并且如果launch使用构建器不需要testCoroutineDispatcher or testCoroutineScope，这是什么原因呢？通常，挂起函数即使在不处于另一个作用域的情况下也会通过runBlockingTest

 @Test
    fun `Given we have a valid request, should be done to correct url`() =
        runBlockingTest {

            // GIVEN
            enqueueResponse(200, RESPONSE_JSON_PATH)

            // WHEN
            launch {
                postApi.getPosts()
            }

            val request = mockWebServer.takeRequest()

            // THEN
            Truth.assertThat(request.path).isEqualTo("/posts")

        }

上面那个有效。

下面的测试有时也通过了。

@测试 乐趣Given api return 200, should have list of posts() = testCoroutineScope.runBlockingTest {

    // GIVEN
    enqueueResponse(200)

    // WHEN
    var posts: List<Post> = emptyList()
    launch {
        posts = postApi.getPosts()
    }

    advanceUntilIdle()

    // THEN
    Truth.assertThat(posts).isNotNull()
    Truth.assertThat(posts.size).isEqualTo(100)

}

我尝试了很多组合调用posts = postApi.getPosts()没有launch, using async, 投入enqueueResponse(200)内部异步async { enqueueResponse(200) }.await()但测试失败了，有时它通过，有时它不通过每个组合。

有一个错误运行块测试 https://github.com/Kotlin/kotlinx.coroutines/issues/1204在完成测试正在运行的协程之前，不等待其他线程/作业完成。

我尝试使用runBlocking成功（我使用了 Hamcrest 到 Kotlin 的出色移植Hamkrest https://github.com/npryce/hamkrest)

fun `run test` = runBlocking {
  mockWebServer.enqueue(MockResponse().setResponseCode(200).setBody(""))

  // make HTTP call 

  val result = mockWebServer.takeRequest(2000L, TimeUnit.MILLISECONDS)

  assertThat(result != null, equalTo(true))
}

这里有几点需要注意：

1. 使用线程阻塞调用应该never被调用而没有超时。总是最好什么都失败，然后永远阻塞线程。

2. 指某东西的用途runBlocking可能有些人认为不行。然而这篇博文 https://craigrussell.io/2019/11/unit-testing-coroutine-suspend-functions-using-testcoroutinedispatcher/概述了运行并发代码的不同方法及其不同的用例。我们通常想要使用runBlockingTest or (TestCoroutineDispatcher.runBlockingTest）以便我们的测试代码和应用程​​序代码同步。通过使用相同的调度程序，我们可以确保作业全部完成，等等。TestCoroutineDispatcher还有方便的“时钟”功能，可以消除延迟。然而，当测试应用程序的 HTTP 层时，如果模拟服务器在单独的线程上运行，我们就有一个同步点：takeRequest。这样我们就可以愉快的使用了runBlocking允许我们使用协程和在不同线程上运行的模拟服务器一起工作，没有任何问题。