assertFailsWith<IOException> {
      response.body.string()
    }
    val callFailed = listener.removeUpToEvent<CallFailed>()
    assertThat(callFailed.ioe).isNotNull()
  }

  @Test
  fun emptyResponseBody() {
    server.enqueue(
      MockResponse
        .Builder()
        .body("")
        .bodyDelay(1, TimeUnit.SECONDS)
        .onResponseBody(CloseSocket())
        .build(),
    )

        while (count < size) {
          sink.write(buffer, 0, Math.min(size - count, writeSize.toLong()).toInt())
          count += writeSize
        }
      }
    }
  }

  @Test
  fun emptyResponseBody() {
    server.enqueue(
      MockResponse(headers = headersOf("abc", "def")),
    )
    executeSynchronously("/")
      .assertCode(200)
      .assertHeader("abc", "def")
      .assertBody("")