public static boolean isFullTopicRanges()

in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/TopicRangeUtils.java [68:89]

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

    public static boolean isFullTopicRanges(List<TopicRange> ranges) {
        List<TopicRange> sorted =
                ranges.stream().sorted(comparingLong(TopicRange::getStart)).collect(toList());
        int start = 0;
        for (TopicRange range : sorted) {
            if (start == 0) {
                if (range.getStart() == 0) {
                    start = range.getEnd();
                    continue;
                } else {
                    return false;
                }
            }

            if (range.getStart() - start != 1) {
                return false;
            }
            start = range.getEnd();
        }

        return start == MAX_RANGE;
    }