trackFailure(e)
      throw e
    }
  }

  @Throws(IOException::class)
  fun peekTrailers(): Headers? = codec.peekTrailers()

  fun upgradeToSocket(): Socket {
    call.timeoutEarlyExit()
    (codec.carrier as RealConnection).useAsSocket()

    eventListener.requestBodyStart(call)

    return object : Socket {
      override fun cancel() {
        ******@****.***()
      }