}

    /**
     * Sets the response body to the UTF-8 encoded bytes of [body],
     * chunked every [maxChunkSize] bytes.
     */
    fun chunkedBody(
      body: String,
      maxChunkSize: Int,
    ): Builder = chunkedBody(Buffer().writeUtf8(body), maxChunkSize)

    /** Sets the headers and returns this. */
    fun headers(headers: Headers) =
      apply {

        .trailers(headersOf("caboose", "xyz"))

    // Trailers always work for HTTP/2, but only for chunked bodies in HTTP/1.
    if (http2) {
      mockResponse.body("abc")
    } else {
      mockResponse.chunkedBody("abc", 1)
    }

    server.enqueue(mockResponse.build())

    val call =
      client.newCall(
        Request(
          url = server.url("/"),
          body = SlowRequestBody,
        ),

      .assertNoMoreLogs()
  }

  @Test
  fun basicChunkedResponseBody() {
    setLevel(Level.BASIC)
    server.enqueue(
      MockResponse.Builder()
        .chunkedBody("Hello!", 2)
        .setHeader("Content-Type", PLAIN)
        .build(),
    )
    val response = client.newCall(request().build()).execute()
    response.body.close()
    applicationLogs

  fun responseHeaders() {
    server.enqueue(
      MockResponse.Builder()
        .status("HTTP/1.0 200 Fantastic")
        .addHeader("A: c")
        .addHeader("B: d")
        .addHeader("A: e")
        .chunkedBody("ABCDE\nFGHIJ\nKLMNO\nPQR", 8)
        .build(),
    )
    val request = newRequest("/")
    val response = getResponse(request)
    assertThat(response.code).isEqualTo(200)

    enableTlsWithTunnel()
    server.protocols = Arrays.asList(Protocol.HTTP_1_1)
    server.enqueue(
      MockResponse.Builder()
        .bodyDelay(100, TimeUnit.MILLISECONDS)
        .chunkedBody("Hello!", 2)
        .build(),
    )
    assertSuccessfulEventOrder(anyResponse)
    assertBytesReadWritten(
      listener,
      CoreMatchers.any(Long::class.java),
      null,
      greaterThan(0L),

  internal enum class TransferKind {
    CHUNKED {
      override fun setBody(
        response: MockResponse.Builder,
        content: Buffer,
        chunkSize: Int,
      ) {
        response.chunkedBody(content, chunkSize)
      }
    },
    FIXED_LENGTH {
      override fun setBody(
        response: MockResponse.Builder,
        content: Buffer,
        chunkSize: Int,
      ) {

    server.enqueue(
      MockResponse.Builder()
        .clearHeaders()
        .addHeader("h1", "v1")
        .addHeader("h2", "v2")
        .chunkedBody("HelloBonjour", 1024)
        .trailers(headersOf("trailers", "boom"))
        .build(),
    )
    val call = client.newCall(Request(server.url("/")))
    val response = call.execute()