) {
          assertThat(inFinished).isFalse()
          assertThat(streamId).isEqualTo(expectedStreamId)
          assertThat(length).isEqualTo(Http2.INITIAL_MAX_FRAME_SIZE)
          val data = source.readByteString(length.toLong())
          for (b in data.toByteArray()) {
            assertThat(b).isEqualTo(2.toByte())
          }
        }
      },
    )
  }

  @Test fun dataFrameNotAssociateWithStream() {

      requestLine = request,
      headers = headers.build(),
      chunkSizes = chunkSizes,
      bodySize = requestBody.receivedByteCount,
      body =
        when {
          hasBody -> requestBody.buffer.readByteString()
          else -> null
        },
      connectionIndex = connectionIndex,
      exchangeIndex = exchangeIndex,
      socket = socket,
      failure = failure,
    )
  }

  private fun ByteString.offByOneBit(): ByteString =
    Buffer()
      .write(this, 0, size - 1)
      .writeByte(this[size - 1].toInt() xor 1)
      .readByteString()

  private fun date(s: String): Date =
    SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSZ").run {
      timeZone = TimeZone.getTimeZone("GMT")
      parse(s)
    }

      assertThat(it).hasMessage("Content-Encoding already set: gzip")
    }
  }

  private fun bodyToHex(body: RequestBody): String {
    val buffer = Buffer()
    body.writeTo(buffer)
    return buffer.readByteString().hex()
  }

HSPLokio/Buffer;->read(Lokio/Buffer;J)J
HSPLokio/Buffer;->read([BII)I
HSPLokio/Buffer;->readByte()B
HSPLokio/Buffer;->readByteArray(J)[B
HSPLokio/Buffer;->readByteString()Lokio/ByteString;
HSPLokio/Buffer;->readByteString(J)Lokio/ByteString;
HSPLokio/Buffer;->readInt()I
HSPLokio/Buffer;->readIntLe()I
HSPLokio/Buffer;->readShort()S
HSPLokio/Buffer;->readString(JLjava/nio/charset/Charset;)Ljava/lang/String;

    assertThat(stream.takeHeaders()).isEqualTo(headersOf("a", "android"))
    val source = stream.source
    assertFailsWith<EOFException> {
      source.buffer().readByteString(101)
    }
  }

  @Test fun blockedStreamDoesntStarveNewStream() {
    val framesThatFillWindow =
      roundUp(Settings.DEFAULT_INITIAL_WINDOW_SIZE, peer.maxOutboundDataLength())

    // The response is not decompressed.
    val response = call.execute()
    assertThat(response.header("Content-Encoding")).isEqualTo("gzip")
    assertThat(response.body.source().readByteString()).isEqualTo(
      gzippedBody.snapshot(),
    )

    // The request did not offer gzip support.
    val recordedRequest = server.takeRequest()