// Settings connection.
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    // Reuse settings connection.
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
    // Reuse settings connection.
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(2)
    // New connection!
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
  }

  @Test

    executeSynchronously("/b").assertBody("def")
    executeSynchronously("/c").assertBody("ghi")
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(2)
  }

  /**
   * Each OkHttpClient used to get its own instance of NullProxySelector, and because these weren't

      assertThat(response.body.string()).isEqualTo("normal request")
    }

    upgrade()

    assertThat(server.takeRequest().connectionIndex).isEqualTo(0)
    assertThat(server.takeRequest().connectionIndex).isEqualTo(0)
  }

  @Test
  fun cannotReuseConnectionAfterUpgrade() {
    upgrade()

    server.enqueue(MockResponse(body = "normal request"))

    assertThat(result).contains(address("157.240.1.18"))
    assertThat(result).contains(address("2a03:2880:f029:11:face:b00c:0:2"))
    val request1 = server.takeRequest()
    assertThat(request1.method).isEqualTo("GET")
    val request2 = server.takeRequest()
    assertThat(request2.method).isEqualTo("GET")
    assertThat(listOf(request1.url.encodedQuery, request2.url.encodedQuery))
      .containsExactlyInAnyOrder(

  RecordedRequest request1 = server.takeRequest();
  assertEquals("/v1/chat/messages/", request1.getUrl().encodedPath());
  assertNotNull(request1.getHeaders().get("Authorization"));

  RecordedRequest request2 = server.takeRequest();
  assertEquals("/v1/chat/messages/2", request2.getUrl().encodedPath());

  RecordedRequest request3 = server.takeRequest();

        .build(),
    )
    newEventSource("text/plain")
    listener.assertOpen()
    listener.assertEvent(null, null, "hey")
    listener.assertClose()
    assertThat(server.takeRequest().headers["Accept"]).isEqualTo("text/plain")
  }

  @Test
  fun setsMissingAccept() {
    server.enqueue(
      MockResponse
        .Builder()
        .body(
          """
          |data: hey

    val call = client.newCall(Request(url))
    val response = call.execute()
    assertThat(response.body.string()).isEqualTo("this was the 2nd request on IPv4")
    assertThat(serverIpv4.takeRequest().exchangeIndex).isEqualTo(0)
    assertThat(serverIpv4.takeRequest().exchangeIndex).isEqualTo(1)
  }

    assertThat(get(url).body.string()).isEqualTo("B")
    assertThat(server.takeRequest().headers["If-None-Match"]).isNull()
    assertThat(server.takeRequest().headers["If-None-Match"]).isEqualTo("v1")
    assertThat(server.takeRequest().headers["If-None-Match"]).isEqualTo("v1")
    assertThat(server.takeRequest().headers["If-None-Match"]).isEqualTo("v2")
  }

  @Test

        .Builder()
        .url(webServer.url("/"))
        .build()
    val response = client.newCall(regularRequest).execute()
    response.close()
    assertThat(webServer.takeRequest().exchangeIndex).isEqualTo(0)
    assertThat(webServer.takeRequest().exchangeIndex).isEqualTo(1)
  }

  /** https://github.com/square/okhttp/issues/5705  */
  @Test
  fun closeWithoutSuccessfulConnect() {
    val request =

        .build()
    val request =
      Request
        .Builder()
        .url(server.url("/"))
        .get()
        .build()
    client.newCall(request).execute()
    val recordedRequest = server.takeRequest()
    assertThat(recordedRequest.method).isEqualTo("POST")
    assertThat(recordedRequest.body?.utf8()).isEqualTo("abc")
  }

  @Test
  fun applicationInterceptorsRewriteRequestToServer() {