@SuppressWarnings("unchecked")
    private EvictingQueue<Double> getSuccessRateQueue() {
        Object field = getField(regulator, "successRateQueue");
        if (field instanceof EvictingQueue) {
            return (EvictingQueue<Double>) field;
        }
        throw new IllegalStateException("Field 'successRateQueue' is not of expected type EvictingQueue<Double>");
    }
Converts a rate given in KB/s to bytes/s.
s3stream/src/test/java/com/automq/stream/s3/operator/TrafficRegulatorTest.java