public static void verifyBatchSize()

in java/e2e-v4/src/main/java/org/apache/rocketmq/utils/VerifyUtils.java [273:290]

• 18 lines of code
• 5 McCabe index (conditional complexity)

    public static void verifyBatchSize(List<Integer> everyConsumeResult, int batchConsumeSize, int lastConsumeSize) {
        boolean result = false;
        if (lastConsumeSize == 0) {
            long s = everyConsumeResult.stream().filter(a -> a == batchConsumeSize).count();
            if (s == everyConsumeResult.size()) {
                result = true;
            }
        } else {
            if (lastConsumeSize == everyConsumeResult.get(everyConsumeResult.size() - 1)) {
                everyConsumeResult.remove(everyConsumeResult.size() - 1);
                long s = everyConsumeResult.stream().filter(a -> a == batchConsumeSize).count();
                if (s == everyConsumeResult.size()) {
                    result = true;
                }
            }
        }
        Assertions.assertTrue(result, "批量消费校验失败");
    }