val algorithm = lookupDecompressor(encoding) ?: return response

    val decompressedSource = algorithm.decompress(body.source()).buffer()

    return response
      .newBuilder()
      .removeHeader("Content-Encoding")
      .removeHeader("Content-Length")
      .body(decompressedSource.asResponseBody(body.contentType(), -1))
      .build()
  }

  internal fun lookupDecompressor(encoding: String): DecompressionAlgorithm? =

    public fun setHeader(
      name: String,
      value: Any,
    ): Builder =
      apply {
        removeHeader(name)
        addHeader(name, value)
      }

    /** Removes all headers named [name]. */
    public fun removeHeader(name: String): Builder =
      apply {
        headers_.removeAll(name)
      }

    open fun addHeader(
      name: String,
      value: String,
    ) = apply {
      headers.add(name, value)
    }

    /** Removes all headers named [name] on this builder. */
    open fun removeHeader(name: String) =
      apply {
        headers.removeAll(name)
      }

    /** Removes all headers on this builder and adds [headers]. */
    open fun headers(headers: Headers) =
      apply {

    mockResponse = mockResponse.addHeaderLenient("", Any())
    mockResponse = mockResponse.setHeader("", Any())
    mockResponse.headers = headersOf()
    mockResponse.trailers = headersOf()
    mockResponse = mockResponse.removeHeader("")
    var body: Buffer? = mockResponse.getBody()
    mockResponse = mockResponse.setBody(Buffer())
    mockResponse = mockResponse.setChunkedBody(Buffer(), 0)
    mockResponse = mockResponse.setChunkedBody("", 0)

    }
  }

  @Test
  fun readEmptyTrailersHttp1UnknownLengthResponse() {
    server.enqueue(
      MockResponse
        .Builder()
        .body("Hello")
        .removeHeader("Content-Length")
        .onResponseEnd(ShutdownConnection)
        .build(),
    )

    val call = client.newCall(Request(server.url("/")))
    call.execute().use { response ->

    open fun addHeader(
      name: String,
      value: String,
    ) = apply {
      headers.add(name, value)
    }

    /** Removes all headers named [name] on this builder. */
    open fun removeHeader(name: String) =
      apply {
        headers.removeAll(name)
      }

    /** Removes all headers on this builder and adds [headers]. */
    open fun headers(headers: Headers) =
      apply {

	public final fun onResponseEnd (Lmockwebserver3/SocketEffect;)Lmockwebserver3/MockResponse$Builder;
	public final fun onResponseStart (Lmockwebserver3/SocketEffect;)Lmockwebserver3/MockResponse$Builder;
	public final fun removeHeader (Ljava/lang/String;)Lmockwebserver3/MockResponse$Builder;
	public final fun setHeader (Ljava/lang/String;Ljava/lang/Object;)Lmockwebserver3/MockResponse$Builder;

      object : Dispatcher() {
        override fun dispatch(request: RecordedRequest): MockResponse =
          upgradeResponse(request)
            .body(Buffer().write("81".decodeHex())) // Truncated frame.
            .removeHeader("Content-Length")
            .build()
      }
    val webSocket: WebSocket = newWebSocket()
    clientListener.assertOpen()
    clientListener.assertFailure(
      SocketTimeoutException::class.java,

	public fun post (Lokhttp3/RequestBody;)Lokhttp3/Request$Builder;
	public fun put (Lokhttp3/RequestBody;)Lokhttp3/Request$Builder;
	public fun query (Lokhttp3/RequestBody;)Lokhttp3/Request$Builder;
	public fun removeHeader (Ljava/lang/String;)Lokhttp3/Request$Builder;
	public fun tag (Ljava/lang/Class;Ljava/lang/Object;)Lokhttp3/Request$Builder;
	public fun tag (Ljava/lang/Object;)Lokhttp3/Request$Builder;

	public fun post (Lokhttp3/RequestBody;)Lokhttp3/Request$Builder;
	public fun put (Lokhttp3/RequestBody;)Lokhttp3/Request$Builder;
	public fun query (Lokhttp3/RequestBody;)Lokhttp3/Request$Builder;
	public fun removeHeader (Ljava/lang/String;)Lokhttp3/Request$Builder;
	public fun tag (Ljava/lang/Class;Ljava/lang/Object;)Lokhttp3/Request$Builder;
	public fun tag (Ljava/lang/Object;)Lokhttp3/Request$Builder;