in src/main/java/com/epam/eco/commons/kafka/OffsetRange.java [111:124]
private final long calculateSize() {
if(largest == smallest) {
return (largestInclusive || smallestInclusive) ? 1 : 0;
} else if(largest == smallest + 1) {
if (largestInclusive && smallestInclusive) {
return 2;
} else if(largestInclusive || smallestInclusive) {
return 1;
} else {
return 0;
}
}
return largest + (largestInclusive ? 1 : 0) - (smallestInclusive ? 0 : 1) - smallest;
}