this.isDuplex = duplex
    val contentLength = request.body!!.contentLength()
    call.eventListener.requestBodyStart(call)
    val rawRequestBody = codec.createRequestBody(request, contentLength)
    return RequestBodySink(
      delegate = rawRequestBody,
      contentLength = contentLength,
      isSocket = false,
    )
  }

  @Throws(IOException::class)
  fun flushRequest() {
    try {
      codec.flushRequest()

        writeHttpResponse(socket, response)
      }

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