this.throttlePeriodNanos = builder.throttlePeriodNanos
    this.failHandshake = builder.failHandshake
    this.onRequestStart = builder.onRequestStart
    this.doNotReadRequestBody = builder.doNotReadRequestBody
    this.onRequestBody = builder.onRequestBody
    this.onResponseStart = builder.onResponseStart
    this.onResponseBody = builder.onResponseBody
    this.onResponseEnd = builder.onResponseEnd

  }

  private fun serverTruncatesRequestOnLongPost(https: Boolean) {
    server.enqueue(
      MockResponse
        .Builder()
        .body("abc")
        .doNotReadRequestBody()
        .build(),
    )

    val call =
      client.newCall(
        Request(
          url = server.url("/"),
          body = SlowRequestBody,
        ),
      )

    SocketPolicy.DISCONNECT_DURING_REQUEST_BODY -> result.onRequestBody(CloseSocket())
    SocketPolicy.DISCONNECT_DURING_RESPONSE_BODY -> result.onResponseBody(CloseSocket())
    SocketPolicy.DO_NOT_READ_REQUEST_BODY -> result.doNotReadRequestBody()
    SocketPolicy.FAIL_HANDSHAKE -> result.failHandshake()
    SocketPolicy.SHUTDOWN_INPUT_AT_END ->
      result.onResponseEnd(
        CloseSocket(
          closeSocket = false,
          shutdownInput = true,

	public synthetic fun clone ()Ljava/lang/Object;
	public fun clone ()Lmockwebserver3/MockResponse$Builder;
	public final fun code (I)Lmockwebserver3/MockResponse$Builder;
	public final fun doNotReadRequestBody ()Lmockwebserver3/MockResponse$Builder;
	public final fun failHandshake ()Lmockwebserver3/MockResponse$Builder;
	public final fun getBody ()Lmockwebserver3/MockResponseBody;
	public final fun getBodyDelayNanos ()J

            socketEffect = peek.onRequestBody,
            expectedByteCount = contentLength,
            socket = socket,
          ).buffer()
      requestBodySink.use {
        when {
          peek.doNotReadRequestBody -> {
            hasBody = false // Ignore the body completely.
          }

          contentLength != -1L -> {
            hasBody = contentLength > 0L || HttpMethod.permitsRequestBody(request.method)

    assertThat(recordedRequest.body).isNull()
  }

  @Test
  fun recordedBodyIsNullWithDoNotRead() {
    server.enqueue(
      MockResponse
        .Builder()
        .doNotReadRequestBody()
        .build(),
    )
    val client = OkHttpClient()
    val request =
      Request(
        url = server.url("/"),
        body = "hello".toRequestBody(),
      )