}
  }

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

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

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

      override val sink =
        RequestBodySink(
          delegate = codec.socket.sink,

      okHttpSocket.sink.timeout().timeout(chain.writeTimeoutMillis.toLong(), MILLISECONDS)
      Http1ExchangeCodec(client, this, okHttpSocket)
    }
  }

  internal fun useAsSocket() {
    javaNetSocket.soTimeout = 0
    noNewExchanges()
  }

  override fun route(): Route = route

  override fun cancel() {
    // Close the raw socket so we don't end up doing synchronous I/O.