private double meanOfTopSuccessRates() {
        if (successRateQueue.isEmpty()) {
            return MIN;
        }

        // Reduce the sample count on warmup
        int topCount = ceilDivide(successRateQueue.size() * TOP_SUCCESS_RATE_COUNT, HISTORY_SIZE);
        List<Double> tops = successRateQueue.stream()
            .collect(Comparators.greatest(topCount, Double::compareTo));
        assert !tops.isEmpty();
        return Stats.meanOf(tops);
    }
The maximum request size allowed by the regulator.
Any request larger than this size should be downscaled to this size.
s3stream/src/main/java/com/automq/stream/s3/operator/TrafficRegulator.java