// Give the server time to disconnect.
    Thread.sleep(500)

    // If the request body is larger than OkHttp's replay buffer, the failure may still occur.
    val requestBodyChars = CharArray(requestSize)
    Arrays.fill(requestBodyChars, 'x')
    val requestBody = String(requestBodyChars)
    for (j in 0..1) {
      try {
        val response =
          getResponse(
            Request(

      .assertFailureMatches(".*unexpected end of stream on " + server.url("/").redact())
  }

  private fun stringFill(
    fillChar: Char,
    length: Int,
  ): String {
    val value = CharArray(length)
    Arrays.fill(value, fillChar)
    return String(value)
  }

  @Test
  fun canceledBeforeExecute() {
    val call = client.newCall(Request.Builder().url(server.url("/a")).build())