.isCloseTo(1500.0, 250.0)

    // The client pinged the server 3 times, and it has ponged back 3 times.
    assertThat(webSocket.sentPingCount()).isEqualTo(3)
    assertThat(server.receivedPingCount()).isEqualTo(3)
    assertThat(webSocket.receivedPongCount()).isEqualTo(3)

    // The server has never pinged the client.
    assertThat(server.receivedPongCount()).isEqualTo(0)

      {
        "lang_en": {
          "match": "*_en-ie",
          "mapping": {
            "type": "text",
            "analyzer": "irish_analyzer"
          }
        }
      },
      {
        "lang_es": {
          "match": "*_es",
          "mapping": {
            "type": "text",
            "analyzer": "spanish_analyzer"
          }
        }
      },
      {
        "lang_et": {

      {
        "lang_en": {
          "match": "*_en-ie",
          "mapping": {
            "type": "text",
            "analyzer": "irish_analyzer"
          }
        }
      },
      {
        "lang_es": {
          "match": "*_es",
          "mapping": {
            "type": "text",
            "analyzer": "spanish_analyzer"
          }
        }
      },
      {
        "lang_et": {

  /** True if this web socket failed and the listener has been notified. */
  private var failed = false

  /** Total number of pings sent by this web socket. */
  private var sentPingCount = 0

  /** Total number of pings received by this web socket. */
  private var receivedPingCount = 0

  /** Total number of pongs received by this web socket. */
  private var receivedPongCount = 0

      {
        "lang_en": {
          "match": "*_en-ie",
          "mapping": {
            "type": "text",
            "analyzer": "irish_analyzer"
          }
        }
      },
      {
        "lang_es": {
          "match": "*_es",
          "mapping": {
            "type": "text",
            "analyzer": "spanish_analyzer"
          }
        }
      },
      {
        "lang_et": {

  private val settingsListenerQueue = taskRunner.newQueue()

  /** User code to run in response to push promise events. */
  private val pushObserver: PushObserver = builder.pushObserver

  // Total number of pings send and received of the corresponding types. All guarded by this.
  private var intervalPingsSent = 0L
  private var intervalPongsReceived = 0L
  private var degradedPingsSent = 0L
  private var degradedPongsReceived = 0L

    client.processNextFrame()
    taskFaker.runTasks()
    server.webSocket!!.pong("pong 3".encodeUtf8())
    client.processNextFrame()

    // After 500ms the client automatically pings and the server pongs back.
    taskFaker.advanceUntil(ns(500L))
    server.processNextFrame() // Ping.
    client.processNextFrame() // Pong.

## Version 4.3.0

_2019-12-31_

 *  Fix: Degrade HTTP/2 connections after a timeout. When an HTTP/2 stream times out it may impact
    the stream only or the entire connection. With this fix OkHttp will now send HTTP/2 pings after
    a stream timeout to determine whether the connection should remain eligible for pooling.

 *  Fix: Don't call `EventListener.responseHeadersStart()` or `responseBodyStart()` until bytes have

  /**
   * The HTTP <a href="http://html.spec.whatwg.org/multipage/semantics.html#hyperlink-auditing">
   * {@code Ping-To}</a> header field name.
   *
   * @since 19.0
   */
  public static final String PING_TO = "Ping-To";

  /**
   * The HTTP <a
   * href="https://developer.mozilla.org/en-US/docs/Web/HTTP/Link_prefetching_FAQ#As_a_server_admin.2C_can_I_distinguish_prefetch_requests_from_normal_requests.3F">{@code