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
    this.shutdownServer = builder.shutdownServer

	public final fun headersDelay (JLjava/util/concurrent/TimeUnit;)Lmockwebserver3/MockResponse$Builder;
	public final fun inTunnel ()Lmockwebserver3/MockResponse$Builder;
	public final fun onRequestBody (Lmockwebserver3/SocketEffect;)Lmockwebserver3/MockResponse$Builder;
	public final fun onRequestStart (Lmockwebserver3/SocketEffect;)Lmockwebserver3/MockResponse$Builder;

  fun requestBodyFailHttp() {
    requestBodyFail(null)
  }

  private fun requestBodyFail(expectedProtocol: Protocol?) {
    server.enqueue(
      MockResponse
        .Builder()
        .onRequestBody(CloseSocket())
        .build(),
    )
    val request = NonCompletingRequestBody()
    val call =
      client.newCallWithListener(
        Request
          .Builder()

    inputStream.close()
  }

  @Test
  fun disconnectRequestHalfway() {
    server.enqueue(
      MockResponse
        .Builder()
        .onRequestBody(CloseSocket())
        .build(),
    )
    // Limit the size of the request body that the server holds in memory to an arbitrary
    // 3.5 MBytes so this test can pass on devices with little memory.

    }

    SocketPolicy.DISCONNECT_AFTER_REQUEST -> {
      result.onResponseStart(CloseSocket())
    }

    SocketPolicy.DISCONNECT_DURING_REQUEST_BODY -> {
      result.onRequestBody(CloseSocket())
    }

    SocketPolicy.DISCONNECT_DURING_RESPONSE_BODY -> {
      result.onResponseBody(CloseSocket())
    }

    SocketPolicy.DO_NOT_READ_REQUEST_BODY -> {
      result.doNotReadRequestBody()

        writeHttpResponse(socket, response)
      }

      val requestBodySink =
        requestBody
          .withThrottlingAndSocketEffect(
            policy = peek,
            socketEffect = peek.onRequestBody,
            expectedByteCount = contentLength,
            socket = socket,
          ).buffer()
      requestBodySink.use {
        when {
          peek.doNotReadRequestBody -> {