latencyMilliSec MetricName = "latency_ms"
	sentBytes       MetricName = "sent_bytes"
	totalBytes      MetricName = "total_bytes"
	usedBytes       MetricName = "used_bytes"
	writeBytes      MetricName = "write_bytes"
	wcharBytes      MetricName = "wchar_bytes"

	latencyMicroSec MetricName = "latency_us"
	latencyNanoSec  MetricName = "latency_ns"

	commitInfo  MetricName = "commit_info"

		err = msgp.WrapError(err, "ReplicationState")
		return
	}
	if z.Data == nil { // allownil: if nil
		err = en.WriteNil()
		if err != nil {
			return
		}
	} else {
		err = en.WriteBytes(z.Data)
		if err != nil {
			err = msgp.WrapError(err, "Data")
			return
		}
	}
	err = en.WriteInt(z.NumVersions)
	if err != nil {
		err = msgp.WrapError(err, "NumVersions")
		return

HSPLokio/Buffer;->write(Lokio/ByteString;)Lokio/Buffer;
HSPLokio/Buffer;->write([B)Lokio/Buffer;
HSPLokio/Buffer;->write([BII)Lokio/Buffer;
HSPLokio/Buffer;->writeAll(Lokio/Source;)J
HSPLokio/Buffer;->writeByte(I)Lokio/Buffer;
HSPLokio/Buffer;->writeByte(I)Lokio/BufferedSink;
HSPLokio/Buffer;->writeInt(I)Lokio/Buffer;
HSPLokio/Buffer;->writeShort(I)Lokio/Buffer;
HSPLokio/Buffer;->writeUtf8(Ljava/lang/String;)Lokio/Buffer;

    }
  }

  @Test
  fun singleByteReadIsSigned() {
    server.enqueue(
      MockResponse
        .Builder()
        .body(
          Buffer()
            .writeByte(-2)
            .writeByte(-1),
        ).build(),
    )
    val response = getResponse(newRequest("/"))
    val inputStream = response.body.byteStream()
    assertThat(inputStream.read()).isEqualTo(254)