writeHttpResponse(socket, sink, response)
      }

      var hasBody = false
      val policy = dispatcher.peek()
      val requestBodySink =
        requestBody.withThrottlingAndSocketPolicy(
          policy = policy,
          disconnectHalfway = policy.socketPolicy == DisconnectDuringRequestBody,
          expectedByteCount = contentLength,
          socket = socket,
        ).buffer()