final Map<String, String> headerMap = new HashMap<>();
        provider.adjustActionResponseHeaders("application/xml", (k, v) -> headerMap.put(k, v));
        assertEquals(2, headerMap.size());
        assertEquals("def", headerMap.get("X-Def"));
        assertEquals("def2", headerMap.get("X-Def2"));
    }

    public void test_write_defaultAndSpecificHtml() throws Exception {

    assertThat(Headers.EMPTY.byteCount()).isEqualTo(0L)
    assertThat(
      Headers
        .Builder()
        .add("abc", "def")
        .build()
        .byteCount(),
    ).isEqualTo(10L)
    assertThat(
      Headers
        .Builder()
        .add("abc", "def")
        .add("ghi", "jkl")
        .build()
        .byteCount(),
    ).isEqualTo(20L)
  }

  @Test fun addDate() {

      Request(
        url = server.url("/"),
        body = "def".toRequestBody("text/plain".toMediaType()),
      )
    executeSynchronously(request)
      .assertCode(200)
      .assertBody("abc")
    val recordedRequest = server.takeRequest()
    assertThat(recordedRequest.method).isEqualTo("POST")
    assertThat(recordedRequest.body?.utf8()).isEqualTo("def")
    assertThat(recordedRequest.headers["Content-Length"]).isEqualTo("3")

  }

  @AfterEach
  fun tearDown() {
    socksProxy.shutdown()
  }

  @Test
  fun proxy() {
    server.enqueue(MockResponse.Builder().body("abc").build())
    server.enqueue(MockResponse.Builder().body("def").build())
    val client =
      clientTestRule
        .newClientBuilder()
        .proxy(socksProxy.proxy())
        .build()
    val request1 = Request.Builder().url(server.url("/")).build()

    assertThat(response1.body.source().readUtf8(3)).isEqualTo("ABC")
    assertThat(response2.body.source().readUtf8(3)).isEqualTo("GHI")
    assertThat(response1.body.source().readUtf8(3)).isEqualTo("DEF")
    assertThat(response2.body.source().readUtf8(3)).isEqualTo("JKL")
    val c0e0 = server.takeRequest()
    assertThat(c0e0.connectionIndex).isEqualTo(0)
    assertThat(c0e0.exchangeIndex).isEqualTo(0)

        // Verify name suffix is set
        assertEquals("Pager", pagerCreator.getNameSuffix());

        // Verify instance def is SESSION
        assertEquals(InstanceDefFactory.SESSION, pagerCreator.getInstanceDef());

        // Verify auto binding def is NONE
        assertEquals(AutoBindingDefFactory.NONE, pagerCreator.getAutoBindingDef());
    }

    // Test getPagerCustomizer when no customizer is set

    server.enqueue(MockResponse(body = "abc"))
    server.enqueue(MockResponse(body = "def"))

    val request = Request(server.url("/"))

    val call = client.newCall(request)
    val response1 = call.execute()

    val cloned = call.clone()
    val response2 = cloned.execute()

    assertThat("abc").isEqualTo(response1.body.string())
    assertThat("def").isEqualTo(response2.body.string())
  }

  @Test
  @Flaky

    assertEquals(
        "\uD8AB\uDCABdef", Strings.commonSuffix("abc\uD8AB\uDCABdef", "xyz\uD8AB\uDCABdef"));
    // Differing valid surrogate pairs.
    assertEquals("def", Strings.commonSuffix("abc\uD8AB\uDCABdef", "abc\uD8AC\uDCABdef"));
    // One invalid pair.
    assertEquals("def", Strings.commonSuffix("abc\uD8AB\uDCABdef", "xyz\uDCAB\uDCABdef"));
    // Two identical invalid pairs.
    assertEquals(

   * | :--------------------- | :----------- |
   * | `http://host/`         | null         |
   * | `http://host/#`        | `""`         |
   * | `http://host/#abc`     | `"abc"`      |
   * | `http://host/#abc|def` | `"abc|def"`  |
   */
  @get:JvmName("fragment") val fragment: String?,
  /** Canonical URL. */
  private val url: String,
) {
  val isHttps: Boolean
    get() = scheme == "https"

    clientListener.assertOpen()
    val server = serverListener.assertOpen()
    webSocket.send("abc")
    serverListener.assertTextMessage("abc")
    server.send("def")
    clientListener.assertTextMessage("def")
    closeWebSockets(webSocket, server)
  }

  @Test
  @Throws(IOException::class)
  fun missingConnectionHeader() {
    webServer.enqueue(
      MockResponse