url = server.url("/"),
          body =
            object : ForwardingRequestBody(transferKind.newRequestBody("def")) {
              override fun writeTo(sink: BufferedSink) {
                sinkReference.set(sink)
                super.writeTo(sink)
              }
            },
        ),
      )
    assertThat(readAscii(response.body.byteStream(), Int.MAX_VALUE))
      .isEqualTo("abc")

      override fun contentLength(): Long {
        return if (chunked) -1L else size
      }

      override fun writeTo(sink: BufferedSink) {
        var count = 0
        while (count < size) {
          sink.write(buffer, 0, Math.min(size - count, writeSize.toLong()).toInt())
          count += writeSize
        }
      }
    }
  }

  @Test

HSPLokhttp3/internal/http2/Hpack$Reader;->readInt(II)I
HSPLokhttp3/internal/http2/Hpack$Writer;-><init>(IZLokio/Buffer;I)V
HSPLokhttp3/internal/http2/Hpack$Writer;->evictToRecoverBytes(I)I
HSPLokhttp3/internal/http2/Hpack$Writer;->insertIntoDynamicTable(Lokhttp3/internal/http2/Header;)V
HSPLokhttp3/internal/http2/Hpack$Writer;->writeByteString(Lokio/ByteString;)V
HSPLokhttp3/internal/http2/Hpack$Writer;->writeHeaders(Ljava/util/List;)V

    val response = builder.build()
    builder.socketPolicy(DisconnectAtEnd)
    val headers = response.headers
    val fullBody = Buffer()
    response.body!!.writeTo(fullBody)
    val truncatedBody = Buffer()
    truncatedBody.write(fullBody, numBytesToKeep.toLong())
    builder.body(truncatedBody)
    builder.headers(headers)
    return builder
  }

  internal enum class TransferKind {

k12.tn.us
k12.tx.us
k12.ut.us
k12.vi.us
k12.vt.us
k12.va.us
k12.wa.us
k12.wi.us
// k12.wv.us  Bug 947705 - Removed at request of Verne Britton <******@****.***>
k12.wy.us
cc.ak.us
cc.al.us
cc.ar.us
cc.as.us
cc.az.us
cc.ca.us
cc.co.us
cc.ct.us
cc.dc.us
cc.de.us
cc.fl.us
cc.ga.us
cc.gu.us
cc.hi.us